Полный проект-пример

examples/basic_app показывает app factory, direct exchange, topology callback, HTTP-публикацию JSON, consumer с явным ack, запись прочитанных данных в consumed.jsonl и dead-letter queue.

cd examples/basic_app
docker compose up -d
python -m venv .venv
. .venv/bin/activate
pip install -r requirements.txt
flask --app basic_app:create_app rmq check
flask --app basic_app:create_app rmq setup

В первом терминале:

flask --app basic_app:create_app rmq consume

Во втором:

flask --app basic_app:create_app run --debug
curl -X POST http://127.0.0.1:5000/events \
  -H 'Content-Type: application/json' \
  -d '{"message":"hello from Flask"}'
tail -f consumed.jsonl

API вернёт 202 Accepted, а событие появится в consumed.jsonl. RabbitMQ Management открыт на http://localhost:15672, локальные credentials — guest / guest.

Остановка: Ctrl+C и docker compose down.