This commit is contained in:
Daniel Thorn 2017-08-02 16:19:33 -07:00
Родитель 3359e8cdd4
Коммит 345b7cc801
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 0CEF54EC2D4A9FE5
1 изменённых файлов: 17 добавлений и 8 удалений

Просмотреть файл

@ -39,19 +39,28 @@ def normalize(fields):
@app.route('/', defaults={'path': ''}, methods=['GET', 'POST'])
@app.route('/<path:path>', methods=['GET', 'POST'])
def catchall(path):
meta = {
'path': path,
'agent': request.headers.get('User-Agent')
'ip': request.headers.get('X-Forwarded-For')
}
data = request.get_json(force=True)
if type(data) is list:
try:
try:
if type(data) is list:
logs = [normalize(item) for item in data]
for item in logs:
log(item)
except TypeError:
log({**item, **meta})
# elif dict type bulk api call:
# logs = [normalize(item) for item in data['bulk']]
# for item in logs:
# log({**item, **meta})
elif type(data) is dict:
log(normalize({**data, **meta}))
else:
return '', 400
elif type(data) is dict:
log(normalize(data))
else:
return '', 204
except TypeError:
return '', 400
return '', 204
@app.route('/__lbheartbeat__')