Compare commits

..

2 Commits

Author SHA1 Message Date
f60e3a3f89 Let data get expired. 2021-06-20 12:19:35 +02:00
29af01c619 Change response codes 2021-06-20 12:15:53 +02:00
2 changed files with 18 additions and 8 deletions

View File

@ -21,6 +21,8 @@ Content type is considered too:
curl -X POST -d '{"key": "value"}' -H 'Content-Type: application/json' http://iot-data.clerie.de/ingress/asdf1234/ curl -X POST -d '{"key": "value"}' -H 'Content-Type: application/json' http://iot-data.clerie.de/ingress/asdf1234/
``` ```
Check for the last data input with the `Last-Modified` header.
## Deployment ## Deployment
Init codebase Init codebase
``` ```
@ -38,12 +40,15 @@ Create `config.json` with the following contents and edit values for your needs:
"key": "asdf1234" "key": "asdf1234"
}, },
"sensor2": { "sensor2": {
"key": "supersecret" "key": "supersecret",
"delete-after": 60
}, },
} }
``` ```
`delete-after`: Specifies the seconds after which the data gets discarded and no data is returned.
Starten und updaten lässt sich die Flask-App folgendermaßen: Starten und updaten lässt sich die Flask-App folgendermaßen:
``` ```
cd iot-data/ cd iot-data/

View File

@ -3,6 +3,7 @@
from flask import Flask, abort, request, make_response from flask import Flask, abort, request, make_response
import json import json
import os import os
import time
app = Flask(__name__) app = Flask(__name__)
@ -32,22 +33,26 @@ def ingress(key):
values[keys[key]] = { values[keys[key]] = {
"payload": request.data, "payload": request.data,
"content-type": content_type, "content-type": content_type,
"last-modified": time.time(),
} }
else: else:
abort(401) return make_response("", 404)
resp = make_response("", 201) return make_response("", 201)
return resp
@app.route("/data/<string:name>/") @app.route("/data/<string:name>/")
def data(name): def data(name):
if not name in config: if not name in config:
abort(404) return make_response("", 404)
if name in values:
if "delete-after" in config[name]:
if (values[name]["last-modified"] + config[name]["delete-after"]) < time.time():
values.pop(name)
if not name in values: if not name in values:
resp = make_response("", 204) return make_response("", 404)
return resp
resp = make_response(values[name]["payload"], 200) resp = make_response(values[name]["payload"], 200)
resp.headers['content-type'] = values[name]["content-type"] resp.headers['Content-Type'] = values[name]["content-type"]
resp.headers['Last-Modified'] = time.strftime("%a, %d %b %Y %H:%M:%S GMT", time.gmtime(values[name]["last-modified"]))
return resp return resp
if __name__ == "__main__": if __name__ == "__main__":