app.py

import logging
import logstash
import random

from flask import Flask, request


app = Flask(__name__)

app.logger = logging.getLogger(__name__)
app.logger.setLevel(logging.INFO)

app.logger.addHandler(logstash.LogstashHandler('logstash', 5044, version=1))
# Handler отвечают за вывод и отправку сообщений. В модуль logging доступно несколько классов-обработчиков
# Например, SteamHandler для записи в поток stdin/stdout, DatagramHandler для UDP, FileHandler для syslog
# LogstashHandler не только отправляет данные по TCP/UDP, но и форматирует логи в json-формат.

logging.basicConfig(level=logging.INFO)


@app.before_request
def before_request():
    request_id = request.headers.get('X-Request-Id')
    if not request_id:
        raise RuntimeError('request id is requred')


@app.route('/')
def index():
    result = random.randint(1, 50)
    app.logger.info(f'Пользователю досталось число {result}')
    return f"Ваше число {result}!"