clerie
/
iot-data
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Let data get expired.

This commit is contained in:
clerie 2021-06-20 12:19:35 +02:00
parent 29af01c619
commit f60e3a3f89
2 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
README.md
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/

9
iot_data/__init__.py
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,6 +33,7 @@ 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:
return make_response("", 404) return make_response("", 404)
@ -42,10 +44,15 @@ def ingress(key):
def data(name): def data(name):
if not name in config: if not name in config:
return make_response("", 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:
return make_response("", 404) return make_response("", 404)
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__":