Документация Flussonic Watcher

Contents

Простой Event коллектор

Приложение принимает POST-запрос, записывает в файл /tmp/events.txt json-объект из запроса и возвращает запрос обратно отправителю.

from flask import Flask, request, jsonify
import json

app=Flask(__name__)

@app.route('/events',methods = ['POST'])
def events():
    d = request.get_json(force=True)

    with open("/tmp/events.txt", "a") as write_events:
        write_events.write(str(d)+'\n')

    return jsonify(d)

app.run(host = '0.0.0.0',debug=true)

Для запуска потребуется gunicorn, его необходимо установить pip3 install gunicorn.

Пример команды для запуска:

gunicorn --bind 0.0.0.0:5000 wsgi:app -D -w 3 --log-syslog --reload -g www-data -u www-data --log-file /var/log/event_coll.log --error-logfile /var/log/event_coll_error.log