Compare commits
2 Commits
519c68c455
...
f60e3a3f89
Author | SHA1 | Date | |
---|---|---|---|
f60e3a3f89 | |||
29af01c619 |
@ -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/
|
||||
```
|
||||
|
||||
Check for the last data input with the `Last-Modified` header.
|
||||
|
||||
## Deployment
|
||||
Init codebase
|
||||
```
|
||||
@ -38,12 +40,15 @@ Create `config.json` with the following contents and edit values for your needs:
|
||||
"key": "asdf1234"
|
||||
},
|
||||
"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:
|
||||
```
|
||||
cd iot-data/
|
||||
|
@ -3,6 +3,7 @@
|
||||
from flask import Flask, abort, request, make_response
|
||||
import json
|
||||
import os
|
||||
import time
|
||||
|
||||
app = Flask(__name__)
|
||||
|
||||
@ -32,22 +33,26 @@ def ingress(key):
|
||||
values[keys[key]] = {
|
||||
"payload": request.data,
|
||||
"content-type": content_type,
|
||||
"last-modified": time.time(),
|
||||
}
|
||||
else:
|
||||
abort(401)
|
||||
return make_response("", 404)
|
||||
|
||||
resp = make_response("", 201)
|
||||
return resp
|
||||
return make_response("", 201)
|
||||
|
||||
@app.route("/data/<string:name>/")
|
||||
def data(name):
|
||||
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:
|
||||
resp = make_response("", 204)
|
||||
return resp
|
||||
return make_response("", 404)
|
||||
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
|
||||
|
||||
if __name__ == "__main__":
|
||||
|
Loading…
Reference in New Issue
Block a user