{"id":473677,"date":"2025-09-02T21:00:17","date_gmt":"2025-09-02T21:00:17","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=473677"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=473677","title":{"rendered":"<span>RabbitMQ \u043a\u0430\u043a \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442 \u00ab\u0434\u0435\u0433\u0440\u0430\u0434\u0430\u0446\u0438\u0438 \u0441 \u0447\u0435\u0441\u0442\u044c\u044e\u00bb<\/span>"},"content":{"rendered":"<div><!--[--><!--]--><\/div>\n<div id=\"post-content-body\">\n<div>\n<div class=\"article-formatted-body article-formatted-body article-formatted-body_version-2\">\n<div xmlns=\"http:\/\/www.w3.org\/1999\/xhtml\">\n<p>\u041f\u0440\u0430\u043a\u0442\u0438\u043a\u0430 outbox, \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0438 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438, DLX \u0438 \u0441\u0445\u0435\u043c\u044b, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0440\u0435\u0430\u043b\u044c\u043d\u043e \u0441\u043f\u0430\u0441\u0430\u044e\u0442 \u043f\u0440\u043e\u0434<\/p>\n<p><strong>\u0421\u0438\u0442\u0443\u0430\u0446\u0438\u044f.<\/strong> REST-\u0432\u044b\u0437\u043e\u0432\u044b \u043c\u0435\u0436\u0434\u0443 \u0441\u0435\u0440\u0432\u0438\u0441\u0430\u043c\u0438 \u043d\u0430\u0447\u0430\u043b\u0438 \u0432\u0430\u043b\u0438\u0442\u044c \u0434\u0440\u0443\u0433 \u0434\u0440\u0443\u0433\u0430: \u0446\u0435\u043f\u043e\u0447\u043a\u0438 \u0437\u0430\u043f\u0440\u043e\u0441\u043e\u0432, \u0442\u0430\u0439\u043c\u0430\u0443\u0442\u044b, \u043a\u0430\u0441\u043a\u0430\u0434\u043d\u044b\u0435 \u0444\u0435\u0439\u043b\u044b. \u041c\u044b \u043f\u0435\u0440\u0435\u0432\u0435\u043b\u0438 \u043a\u043e\u043c\u043c\u0443\u043d\u0438\u043a\u0430\u0446\u0438\u044e \u043d\u0430 RabbitMQ \u2013 \u0438 \u0434\u043e\u0431\u0438\u043b\u0438\u0441\u044c \u043d\u0435 \u00ab\u0431\u0435\u0437\u043e\u0448\u0438\u0431\u043e\u0447\u043d\u043e\u0441\u0442\u0438\u00bb, \u0430 <strong>\u043f\u0440\u0435\u0434\u0441\u043a\u0430\u0437\u0443\u0435\u043c\u043e\u0439 \u0434\u0435\u0433\u0440\u0430\u0434\u0430\u0446\u0438\u0438<\/strong>: \u0434\u0430\u043d\u043d\u044b\u0435 \u043d\u0435 \u0442\u0435\u0440\u044f\u044e\u0442\u0441\u044f, \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e\u0435 \u2013 \u0435\u0434\u0435\u0442 \u043f\u0435\u0440\u0432\u044b\u043c, \u044f\u0434 \u0431\u044b\u0441\u0442\u0440\u0435\u0435 \u0432\u043e\u0441\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u0435\u0442\u0441\u044f<\/p>\n<p>\u041d\u0438\u0436\u0435 \u2013 \u0442\u043e\u043b\u044c\u043a\u043e \u043f\u0440\u0438\u043a\u043b\u0430\u0434\u043d\u043e\u0435: \u043f\u0440\u043e\u0432\u0435\u0440\u0435\u043d\u043d\u044b\u0435 \u043f\u0430\u0442\u0442\u0435\u0440\u043d\u044b, \u0433\u043e\u0442\u043e\u0432\u044b\u0435 \u0444\u0440\u0430\u0433\u043c\u0435\u043d\u0442\u044b \u043a\u043e\u0434\u0430 (Python \/ aio-pika), \u0438 \u0441\u0445\u0435\u043c\u044b, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043c\u043e\u0436\u043d\u043e \u0441\u0440\u0430\u0437\u0443 \u0432\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u0442\u044c<\/p>\n<h3>\u0411\u0430\u0437\u0430: \u00ab\u0434\u0435\u0433\u0440\u0430\u0434\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441 \u0447\u0435\u0441\u0442\u044c\u044e\u00bb \u2013 \u044d\u0442\u043e \u043a\u0430\u043a?<\/h3>\n<p>\u041f\u0440\u0438\u043d\u0446\u0438\u043f \u043f\u0440\u043e\u0441\u0442\u043e\u0439: \u0435\u0441\u043b\u0438 \u0431\u0440\u043e\u043a\u0435\u0440, \u043f\u043e\u0442\u0440\u0435\u0431\u0438\u0442\u0435\u043b\u0438 \u0438\u043b\u0438 \u0441\u0435\u0442\u044c \u00ab\u0441\u044b\u043f\u044f\u0442\u0441\u044f\u00bb, <strong>\u0441\u0438\u0441\u0442\u0435\u043c\u0430 \u043d\u0435 \u043b\u043e\u043c\u0430\u0435\u0442 \u0431\u0438\u0437\u043d\u0435\u0441-\u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 \u0438 \u043d\u0435 \u0442\u0435\u0440\u044f\u0435\u0442 \u0441\u043e\u0431\u044b\u0442\u0438\u0439<\/strong>, \u0430:<\/p>\n<ul>\n<li>\n<p>\u0412\u0440\u0435\u043c\u0435\u043d\u043d\u043e <strong>\u0431\u0443\u0444\u0435\u0440\u0438\u0437\u0443\u0435\u0442<\/strong><\/p>\n<\/li>\n<li>\n<p><strong>\u0420\u0430\u0441\u0441\u0442\u0430\u0432\u043b\u044f\u0435\u0442 \u043f\u0440\u0438\u043e\u0440\u0438\u0442\u0435\u0442\u044b<\/strong><\/p>\n<\/li>\n<li>\n<p><strong>\u041e\u0442\u0431\u0438\u0432\u0430\u0435\u0442 \u044f\u0434<\/strong> \u043e\u0442 \u00ab\u044f\u0434\u043e\u0432\u0438\u0442\u044b\u0445\u00bb \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439<\/p>\n<\/li>\n<li>\n<p>\u0412<strong>\u043e\u0441\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u0435\u0442\u0441\u044f<\/strong> \u0434\u043e \u0441\u043e\u0433\u043b\u0430\u0441\u043e\u0432\u0430\u043d\u043d\u043e\u0433\u043e \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u044f<\/p>\n<\/li>\n<\/ul>\n<p>\u0412 RabbitMQ \u044d\u0442\u043e \u0441\u043e\u0431\u0438\u0440\u0430\u0435\u0442\u0441\u044f \u0438\u0437 \u0447\u0435\u0442\u044b\u0440\u0451\u0445 \u043a\u0438\u0440\u043f\u0438\u0447\u0435\u0439:<\/p>\n<ol>\n<li>\n<p><strong>Transactional Outbox<\/strong> (\u0441\u043e\u0431\u044b\u0442\u0438\u044f \u0432 \u0441\u0432\u043e\u0435\u0439 \u0411\u0414 \u0434\u043e \u0431\u0440\u043e\u043a\u0435\u0440\u0430)<\/p>\n<\/li>\n<li>\n<p><strong>\u0411\u0435\u0437\u043e\u043f\u0430\u0441\u043d\u0430\u044f \u043f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u044f<\/strong> (publisher confirms + mandatory \/ AE)<\/p>\n<\/li>\n<li>\n<p><strong>\u0411\u0435\u0437\u043e\u043f\u0430\u0441\u043d\u043e\u0435 \u043f\u043e\u0442\u0440\u0435\u0431\u043b\u0435\u043d\u0438\u0435<\/strong> (\u0440\u0443\u0447\u043d\u044b\u0435 ack \/ nack, DLX, \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c)<\/p>\n<\/li>\n<li>\n<p><strong>\u041a\u043e\u043d\u0442\u0440\u043e\u043b\u044c \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438<\/strong> (prefetch, TTL, max-length, \u043f\u0440\u0438\u043e\u0440\u0438\u0442\u0435\u0442\u044b \/ \u0440\u0430\u0437\u0434\u0435\u043b\u0435\u043d\u0438\u0435 \u043e\u0447\u0435\u0440\u0435\u0434\u0435\u0439)<\/p>\n<\/li>\n<\/ol>\n<h3>\u0428\u0430\u0433 1. Transactional Outbox \u2013 \u043d\u0438\u043a\u0430\u043a\u0438\u0445 \u043f\u043e\u0442\u0435\u0440\u044c \u043f\u0440\u0438 \u043f\u0430\u0434\u0435\u043d\u0438\u0438 \u0431\u0440\u043e\u043a\u0435\u0440\u0430<\/h3>\n<p>\u0421\u0443\u0442\u044c: \u0432\u043c\u0435\u0441\u0442\u0435 \u0441 \u0437\u0430\u043f\u0438\u0441\u044c\u044e \u0431\u0438\u0437\u043d\u0435\u0441-\u0441\u043e\u0431\u044b\u0442\u0438\u044f \u043f\u0438\u0448\u0435\u043c \u0441\u0442\u0440\u043e\u043a\u0443 \u0432 <code>outbox<\/code> \u0432 <strong>\u0442\u043e\u0439 \u0436\u0435 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438<\/strong>. \u0424\u043e\u043d\u043e\u0432\u044b\u0439 \u0432\u043e\u0440\u043a\u0435\u0440 \u043f\u0443\u0431\u043b\u0438\u043a\u0443\u0435\u0442 \u0432 RabbitMQ \u0441 \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u044f\u043c\u0438; \u043f\u0440\u0438 \u0441\u0431\u043e\u044f\u0445 \u2013 \u0440\u0435\u0442\u0440\u0430\u0438\u0442. \u0421\u043e\u0431\u044b\u0442\u0438\u0435 \u043d\u0435 \u00ab\u0438\u0441\u0447\u0435\u0437\u043d\u0435\u0442\u00bb \u043c\u0435\u0436\u0434\u0443 \u0411\u0414 \u0438 \u0431\u0440\u043e\u043a\u0435\u0440\u043e\u043c<\/p>\n<figure class=\"full-width\"><img decoding=\"async\" src=\"https:\/\/habrastorage.org\/r\/w1560\/getpro\/habr\/upload_files\/703\/511\/a1a\/703511a1a39d0305600e6e0477e7aaa0.png\" alt=\"\u0410\u0440\u0445\u0438\u0442\u0435\u043a\u0442\u0443\u0440\u0430 \u0441 Outbox, AE \u0438 DLX\" title=\"\u0410\u0440\u0445\u0438\u0442\u0435\u043a\u0442\u0443\u0440\u0430 \u0441 Outbox, AE \u0438 DLX\" width=\"2689\" height=\"208\" sizes=\"auto, (max-width: 780px) 100vw, 50vw\" srcset=\"https:\/\/habrastorage.org\/r\/w780\/getpro\/habr\/upload_files\/703\/511\/a1a\/703511a1a39d0305600e6e0477e7aaa0.png 780w,&#10;       https:\/\/habrastorage.org\/r\/w1560\/getpro\/habr\/upload_files\/703\/511\/a1a\/703511a1a39d0305600e6e0477e7aaa0.png 781w\" loading=\"lazy\" decode=\"async\"\/><\/p>\n<div><figcaption>\u0410\u0440\u0445\u0438\u0442\u0435\u043a\u0442\u0443\u0440\u0430 \u0441 Outbox, AE \u0438 DLX<\/figcaption><\/div>\n<\/figure>\n<p><strong>DDL (PostgreSQL):<\/strong><\/p>\n<pre><code class=\"python\">create table outbox (   id            uuid primary key,   aggregate     text not null,   event_type    text not null,   payload       jsonb not null,   created_at    timestamptz not null default now(),   status        text not null default 'NEW',      -- NEW|SENT|FAILED   attempts      int  not null default 0,   next_retry_at timestamptz );  create index on outbox (status, next_retry_at);<\/code><\/pre>\n<p><strong>\u0412\u043e\u0440\u043a\u0435\u0440 \u043f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u0438 (Python, aio-pika, \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u044f + mandatory):<\/strong><\/p>\n<pre><code class=\"python\">import asyncio, json, uuid, asyncpg from aio_pika import connect_robust, Message, DeliveryMode, RobustConnection, RobustChannel, ExchangeType from datetime import datetime, timedelta  AMQP_URL = \"amqp:\/\/user:pass@rabbit:5672\/%2F\" EXCHANGE = \"events.topic\"  async def publish_outbox_batch(pool):     conn: RobustConnection = await connect_robust(AMQP_URL)     ch: RobustChannel = await conn.channel(publisher_confirms=True)     exchange = await ch.declare_exchange(EXCHANGE, ExchangeType.TOPIC, durable=True,                                          arguments={\"alternate-exchange\": \"events.ae\"})  # AE \u043d\u0430 \u0441\u043b\u0443\u0447\u0430\u0439 unroutable     while True:         async with pool.acquire() as db:             rows = await db.fetch(\"\"\"               update outbox                  set status='IN_PROGRESS'                where id in (                  select id from outbox                   where status='NEW'                      or (status='FAILED' and (next_retry_at is null or next_retry_at &lt;= now()))                   order by created_at                   limit 200                )              returning id, event_type, payload             \"\"\")         if not rows:             await asyncio.sleep(0.3)             continue          to_ack, to_fail = [], []         for r in rows:             body = json.dumps(r[\"payload\"]).encode()             msg = Message(                 body,                 delivery_mode=DeliveryMode.PERSISTENT,                 message_id=str(uuid.uuid4()),                 content_type=\"application\/json\",                 headers={\"event_type\": r[\"event_type\"]},             )             routing_key = f\"{r['event_type']}\"             try:                 # mandatory=True - UnroutableError, \u0435\u0441\u043b\u0438 \u043d\u0435\u043a\u0443\u0434\u0430 \u0434\u043e\u0441\u0442\u0430\u0432\u0438\u0442\u044c                 await exchange.publish(msg, routing_key=routing_key, mandatory=True)                 to_ack.append(r[\"id\"])             except Exception:                 to_fail.append(r[\"id\"])          async with pool.acquire() as db:             if to_ack:                 await db.execute(\"update outbox set status='SENT' where id = any($1)\", to_ack)             if to_fail:                 await db.execute(\"\"\"                   update outbox                      set status='FAILED',                          attempts = attempts + 1,                          next_retry_at = now() + ((least(attempts, 10)) * interval '10 seconds')                    where id = any($1)                 \"\"\", to_fail)  async def main():     pool = await asyncpg.create_pool(dsn=\"postgres:\/\/user:pass@db\/app\")     await publish_outbox_batch(pool)  asyncio.run(main())<\/code><\/pre>\n<p><strong>\u0427\u0442\u043e \u0432\u0430\u0436\u043d\u043e:<\/strong><\/p>\n<ul>\n<li>\n<p><code>publisher_confirms=True<\/code> \u2013 \u0436\u0434\u0451\u043c \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u0435 \u0431\u0440\u043e\u043a\u0435\u0440\u0430<\/p>\n<\/li>\n<li>\n<p><code>mandatory=True<\/code> + <strong>alternate-exchange<\/strong> (AE) \u2013 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0440\u0443\u0435\u043c, \u0447\u0442\u043e <strong>\u043d\u0438 \u043e\u0434\u043d\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043d\u0435 \u0443\u0439\u0434\u0451\u0442 \u0432 \u00ab\u0432\u0430\u043a\u0443\u0443\u043c\u00bb<\/strong><\/p>\n<\/li>\n<li>\n<p>\u042d\u043a\u0441\u043f\u043e\u043d\u0435\u043d\u0446\u0438\u0430\u043b\u044c\u043d\u044b\u0439 backoff \u043f\u043e <code>attempts<\/code> \u2013 <strong>\u043d\u0435 \u0434\u0443\u0448\u0438\u043c<\/strong> \u0431\u0440\u043e\u043a\u0435\u0440 \u043f\u0440\u0438 \u0432\u043e\u0441\u0441\u0442\u0430\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u0438<\/p>\n<\/li>\n<\/ul>\n<h3>\u0428\u0430\u0433 2. \u041f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u044f \u0441 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u044f\u043c\u0438: confirms, mandatory, AE<\/h3>\n<ul>\n<li>\n<p><strong>Publisher Confirms<\/strong>: \u0431\u0440\u043e\u043a\u0435\u0440 \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0430\u0435\u0442 \u043f\u0440\u0438\u0451\u043c (\u043f\u0435\u0440-\u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438\u043b\u0438 \u0431\u0430\u0442\u0447\u0435\u043c)<\/p>\n<\/li>\n<li>\n<p><strong>mandatory<\/strong>: \u0435\u0441\u043b\u0438 \u043d\u0438 \u043e\u0434\u043d\u0430 \u043f\u0440\u0438\u0432\u044f\u0437\u043a\u0430 \u043d\u0435 \u043f\u043e\u0434\u0445\u043e\u0434\u0438\u0442, \u0431\u0440\u043e\u043a\u0435\u0440 \u0432\u0435\u0440\u043d\u0451\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 (\u0438\u043b\u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442 \u0432 AE)<\/p>\n<\/li>\n<li>\n<p><strong>Alternate Exchange (AE)<\/strong>: \u0437\u0430\u043f\u0430\u0441\u043d\u043e\u0439 \u043e\u0431\u043c\u0435\u043d\u043d\u0438\u043a \u0434\u043b\u044f <strong>unroutable<\/strong> \u2013 \u0441\u043a\u043b\u0430\u0434\u044b\u0432\u0430\u0435\u043c \u0442\u0443\u0434\u0430 \u0438 \u0430\u043b\u0435\u0440\u0442\u0438\u043c<\/p>\n<\/li>\n<\/ul>\n<figure class=\"full-width\"><img decoding=\"async\" src=\"https:\/\/habrastorage.org\/r\/w1560\/getpro\/habr\/upload_files\/0d4\/866\/fa0\/0d4866fa032c0f70b37f9defd150abef.png\" alt=\"\u041f\u043e\u0441\u043b\u0435\u0434\u043e\u0432\u0430\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c \u043f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u0438 \" title=\"\u041f\u043e\u0441\u043b\u0435\u0434\u043e\u0432\u0430\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c \u043f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u0438 \" width=\"1226\" height=\"206\" sizes=\"auto, (max-width: 780px) 100vw, 50vw\" srcset=\"https:\/\/habrastorage.org\/r\/w780\/getpro\/habr\/upload_files\/0d4\/866\/fa0\/0d4866fa032c0f70b37f9defd150abef.png 780w,&#10;       https:\/\/habrastorage.org\/r\/w1560\/getpro\/habr\/upload_files\/0d4\/866\/fa0\/0d4866fa032c0f70b37f9defd150abef.png 781w\" loading=\"lazy\" decode=\"async\"\/><\/p>\n<div><figcaption>\u041f\u043e\u0441\u043b\u0435\u0434\u043e\u0432\u0430\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c \u043f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u0438<strong> <\/strong><\/figcaption><\/div>\n<\/figure>\n<p><strong>\u0422\u043e\u043f\u043e\u043b\u043e\u0433\u0438\u044f (\u043e\u0431\u044a\u044f\u0432\u043b\u0435\u043d\u0438\u0435 \u043e\u0431\u043c\u0435\u043d\u043d\u0438\u043a\u043e\u0432 \u0438 AE):<\/strong><\/p>\n<pre><code class=\"python\"># \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u0439 \u043e\u0431\u043c\u0435\u043d\u043d\u0438\u043a \u0441\u043e\u0431\u044b\u0442\u0438\u0439 await ch.declare_exchange(\"events.topic\", ExchangeType.TOPIC, durable=True,                           arguments={\"alternate-exchange\": \"events.ae\"}) # AE \u0434\u043b\u044f \u043d\u0435 \u043c\u0430\u0440\u0448\u0440\u0443\u0442\u0438\u0437\u043e\u0432\u0430\u043d\u043d\u044b\u0445 await ch.declare_exchange(\"events.ae\", ExchangeType.FANOUT, durable=True) # \u043e\u0447\u0435\u0440\u0435\u0434\u044c-\u043f\u0430\u0440\u043a\u043e\u0432\u043a\u0430 \u0434\u043b\u044f unroutable q_ae = await ch.declare_queue(\"events.unroutable\", durable=True) await q_ae.bind(\"events.ae\", routing_key=\"\")<\/code><\/pre>\n<h3>\u0428\u0430\u0433 3. \u041f\u043e\u0442\u0440\u0435\u0431\u043b\u0435\u043d\u0438\u0435 \u0431\u0435\u0437 \u0441\u044e\u0440\u043f\u0440\u0438\u0437\u043e\u0432: ack \/ nack, DLX, \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c<\/h3>\n<p><strong>\u0426\u0435\u043b\u0438:<\/strong><\/p>\n<ul>\n<li>\n<p>\u041d\u0435 \u0442\u0435\u0440\u044f\u0435\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f<\/p>\n<\/li>\n<li>\n<p>\u041d\u0435 \u0437\u0430\u0446\u0438\u043a\u043b\u0438\u0432\u0430\u0435\u043c \u00ab\u044f\u0434\u043e\u0432\u0438\u0442\u044b\u0435\u00bb<\/p>\n<\/li>\n<li>\n<p>\u041e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u043c <strong>\u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e<\/strong> (\u0434\u0443\u0431\u043b\u0438\u043a\u0430\u0442\u044b \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u044b)<\/p>\n<\/li>\n<\/ul>\n<p><strong>\u041e\u0447\u0435\u0440\u0435\u0434\u044c \u0441 DLX \/ TTL \/ \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d\u0438\u0435\u043c:<\/strong><\/p>\n<pre><code class=\"python\"># Dead-letter exchange await ch.declare_exchange(\"events.dlx\", ExchangeType.TOPIC, durable=True)  args = {     \"x-dead-letter-exchange\": \"events.dlx\",     \"x-dead-letter-routing-key\": \"dead.order\",   # \u0438\u043b\u0438 \u043f\u043e \u0448\u0430\u0431\u043b\u043e\u043d\u0443     \"x-message-ttl\": 10_000,                     # TTL \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0432 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 (\u043f\u0440\u0438\u043c\u0435\u0440)     \"x-max-length\": 50_000,                      # \u0437\u0430\u0449\u0438\u0442\u0438\u043c\u0441\u044f \u043e\u0442 \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u043e\u0433\u043e \u0440\u043e\u0441\u0442\u0430     \"x-queue-mode\": \"lazy\",                      # \u043a\u0440\u0443\u043f\u043d\u044b\u0435 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 - \u043d\u0430 \u0434\u0438\u0441\u043a     \"x-max-priority\": 10,                        # \u0435\u0441\u043b\u0438 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0435 \u043f\u0440\u0438\u043e\u0440\u0438\u0442\u0435\u0442\u044b }  q = await ch.declare_queue(\"order.events\", durable=True, arguments=args) await q.bind(\"events.topic\", routing_key=\"order.*\")<\/code><\/pre>\n<p><strong>\u0418\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u044b\u0439 consumer (\u0441 \u0443\u0447\u0451\u0442\u043e\u043c \u0434\u0443\u0431\u043b\u0438\u043a\u0430\u0442\u043e\u0432 \u0438 \u00ab\u044f\u0434\u043e\u0432\u0438\u0442\u044b\u0445\u00bb): <\/strong>\u043a\u0430\u043a \u043d\u0435 \u043f\u043e\u0442\u0435\u0440\u044f\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043f\u0440\u0438 \u0441\u0431\u043e\u0435<\/p>\n<pre><code class=\"python\">import hashlib, aioredis  redis = await aioredis.from_url(\"redis:\/\/redis:6379\/0\")  def seen_key(message_id: str) -&gt; str:     return f\"seen:{message_id}\"  async def handle(message):     # \u0431\u0438\u0437\u043d\u0435\u0441-\u043b\u043e\u0433\u0438\u043a\u0430     ...  async def consume(message):     async with message.process(ignore_processed=True):  # manual ack \/ nack \u0432\u043d\u0443\u0442\u0440\u0438 \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u0430         mid = message.message_id or hashlib.sha1(message.body).hexdigest()          # \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c: \u0443\u0436\u0435 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u043b\u0438?         if await redis.setnx(seen_key(mid), \"1\"):             await redis.expire(seen_key(mid), 24*3600)  # \u0445\u0440\u0430\u043d\u0438\u0442\u044c \u0441\u0443\u0442\u043a\u0438 \/ \u043d\u0435\u0434\u0435\u043b\u044e - \u043f\u043e \u043e\u0431\u044a\u0451\u043c\u0443             try:                 await handle(message)                 # ack \u043f\u0440\u043e\u0438\u0437\u043e\u0439\u0434\u0451\u0442 \u043f\u0440\u0438 \u0432\u044b\u0445\u043e\u0434\u0435 \u0438\u0437 \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u0430             except TransientError:                 # \u0432\u0440\u0435\u043c\u0435\u043d\u043d\u0430\u044f \u043e\u0448\u0438\u0431\u043a\u0430 - \u0432\u0435\u0440\u043d\u0451\u043c \u0432 \u043e\u0447\u0435\u0440\u0435\u0434\u044c (\u0441 \u0443\u0447\u0451\u0442\u043e\u043c TTL \/ DLX \/ \u043f\u043e\u0432\u0442\u043e\u0440\u043d\u044b\u0445 \u043f\u043e\u043f\u044b\u0442\u043e\u043a)                 await message.nack(requeue=True)             except Exception:                 # \u044f\u0434 - \u0432 DLX, \u0447\u0442\u043e\u0431\u044b \u043d\u0435 \u043a\u0440\u0443\u0442\u0438\u0442\u044c \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u043e                 await message.reject(requeue=False)         else:             # \u0434\u0443\u0431\u043b\u0438\u043a\u0430\u0442 - \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0430\u0435\u043c \u0442\u0438\u0445\u043e             return  await q.consume(consume, no_ack=False) await ch.set_qos(prefetch_count=64)  # \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044c \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438<\/code><\/pre>\n<p><strong>\u0417\u0430\u0447\u0435\u043c DLX:<\/strong> \u00ab\u044f\u0434\u043e\u0432\u0438\u0442\u044b\u0435\u00bb \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u043f\u043e\u043f\u0430\u0434\u0430\u044e\u0442 \u0432 \u00ab\u043a\u043b\u0430\u0434\u0431\u0438\u0449\u0435\u00bb (parking lot). \u0422\u0430\u043c \u0438\u0445 \u043c\u043e\u0436\u043d\u043e \u0440\u0443\u043a\u0430\u043c\u0438 \u0440\u0430\u0437\u0431\u0438\u0440\u0430\u0442\u044c \u0438\u043b\u0438 \u043f\u0435\u0440\u0435\u0438\u0433\u0440\u044b\u0432\u0430\u0442\u044c \u0447\u0435\u0440\u0435\u0437 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0439 \u00ab\u0440\u0435-\u043f\u0440\u043e\u0446\u0435\u0441\u0441\u043e\u0440\u00bb<\/p>\n<figure class=\"full-width\"><img decoding=\"async\" src=\"https:\/\/habrastorage.org\/r\/w1560\/getpro\/habr\/upload_files\/048\/082\/33c\/04808233c0367c1de5798cd8774eea72.png\" alt=\"\u041f\u043e\u0442\u0440\u0435\u0431\u043b\u0435\u043d\u0438\u0435 \u0441 \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c\u044e \u0438 DLX\" title=\"\u041f\u043e\u0442\u0440\u0435\u0431\u043b\u0435\u043d\u0438\u0435 \u0441 \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c\u044e \u0438 DLX\" width=\"1261\" height=\"122\" sizes=\"auto, (max-width: 780px) 100vw, 50vw\" srcset=\"https:\/\/habrastorage.org\/r\/w780\/getpro\/habr\/upload_files\/048\/082\/33c\/04808233c0367c1de5798cd8774eea72.png 780w,&#10;       https:\/\/habrastorage.org\/r\/w1560\/getpro\/habr\/upload_files\/048\/082\/33c\/04808233c0367c1de5798cd8774eea72.png 781w\" loading=\"lazy\" decode=\"async\"\/><\/p>\n<div><figcaption>\u041f\u043e\u0442\u0440\u0435\u0431\u043b\u0435\u043d\u0438\u0435 \u0441 \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c\u044e \u0438 DLX<\/figcaption><\/div>\n<\/figure>\n<h3>\u0428\u0430\u0433 4. \u041f\u0440\u0438\u043e\u0440\u0438\u0442\u0435\u0442\u044b \u0438 \u0440\u0430\u0437\u0434\u0435\u043b\u0435\u043d\u0438\u0435 \u043f\u0443\u0442\u0435\u0439: \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e\u0435 \u0435\u0434\u0435\u0442 \u043f\u0435\u0440\u0432\u044b\u043c<\/h3>\n<p>\u0427\u0430\u0441\u0442\u0430\u044f \u043e\u0448\u0438\u0431\u043a\u0430 \u2013 \u00ab\u043e\u0434\u043d\u0430 \u043e\u0447\u0435\u0440\u0435\u0434\u044c \u043d\u0430 \u0432\u0441\u0451\u00bb. \u0412 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u0435 \u0443\u0432\u0435\u0434\u043e\u043c\u043b\u0435\u043d\u0438\u044f \u0437\u0430\u0431\u0438\u0432\u0430\u044e\u0442 \u043f\u043e\u043b\u043e\u0441\u0443, \u0430 \u0434\u0435\u043d\u044c\u0433\u0438 \/ \u0437\u0430\u043a\u0430\u0437\u044b \u0436\u0434\u0443\u0442<\/p>\n<p><strong>\u041f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e:<\/strong><\/p>\n<ul>\n<li>\n<p>\u0420\u0430\u0437\u0434\u0435\u043b\u044f\u0435\u043c \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e\u0435 \u0438 \u0444\u043e\u043d\u043e\u0432\u043e\u0435 \u043f\u043e <strong>\u0440\u0430\u0437\u043d\u044b\u043c \u043e\u0447\u0435\u0440\u0435\u0434\u044f\u043c \/ \u043a\u043b\u044e\u0447\u0430\u043c<\/strong><\/p>\n<\/li>\n<li>\n<p>\u0414\u043b\u044f \u0444\u043e\u043d\u043e\u0432\u043e\u0433\u043e \u2013 <strong>TTL + max-length<\/strong> (\u0433\u043e\u0442\u043e\u0432\u044b \u0442\u0435\u0440\u044f\u0442\u044c \u00ab\u0445\u0432\u043e\u0441\u0442\u00bb \u043f\u0440\u0438 \u0430\u0432\u0430\u0440\u0438\u0438)<\/p>\n<\/li>\n<li>\n<p>\u0414\u043b\u044f \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e\u0433\u043e \u2013 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0435 \u0432\u043e\u0440\u043a\u0435\u0440\u044b \u0438 \u043c\u0435\u043d\u044c\u0448\u0438\u0439 prefetch (\u0431\u044b\u0441\u0442\u0440\u0435\u0435 \u0440\u0435\u0430\u043a\u0446\u0438\u044f)<\/p>\n<\/li>\n<\/ul>\n<p><strong>\u041f\u0440\u0438\u043c\u0435\u0440:<\/strong><\/p>\n<pre><code class=\"python\"># \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u0430\u044f \u043e\u0447\u0435\u0440\u0435\u0434\u044c (\u043e\u043f\u043b\u0430\u0442\u0430) await ch.declare_queue(\"billing.high\", durable=True,                        arguments={\"x-dead-letter-exchange\": \"events.dlx\"}) await ch.queue_bind(\"billing.high\", \"events.topic\", routing_key=\"billing.*\")  # \u0444\u043e\u043d\u043e\u0432\u0430\u044f (email): TTL + max-length, \u043f\u0443\u0441\u0442\u044c \u0434\u0435\u0433\u0440\u0430\u0434\u0438\u0440\u0443\u0435\u0442 \u043f\u0435\u0440\u0432\u043e\u0439 await ch.declare_queue(\"notify.low\", durable=True,   arguments={     \"x-dead-letter-exchange\": \"events.dlx\",     \"x-message-ttl\": 60_000,     \"x-max-length\": 20_000 }) await ch.queue_bind(\"notify.low\", \"events.topic\", routing_key=\"notify.*\")<\/code><\/pre>\n<h3>\u041d\u0430\u0431\u043e\u0440 \u00ab\u0433\u0440\u0430\u0431\u043b\u0435\u0439\u00bb \u0438 \u043a\u0430\u043a \u043c\u044b \u0438\u0445 \u043e\u0431\u0445\u043e\u0434\u0438\u043b\u0438<\/h3>\n<ul>\n<li>\n<p><strong>\u0411\u043e\u043b\u044c\u0448\u0438\u0435 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 = \u0430\u043d\u0442\u0438\u043f\u0430\u0442\u0442\u0435\u0440\u043d.<\/strong> \u0414\u0435\u043b\u0430\u0439\u0442\u0435 \u043a\u043e\u0440\u043e\u0442\u043a\u0438\u043c\u0438: <code>x-message-ttl<\/code>, <code>x-max-length<\/code>, \u00ab\u043b\u0435\u043d\u0438\u0432\u044b\u0435\u00bb (<code>x-queue-mode=lazy<\/code>) \u0442\u043e\u043b\u044c\u043a\u043e \u0442\u0430\u043c, \u0433\u0434\u0435 \u043e\u0441\u043e\u0437\u043d\u0430\u043d\u043d\u043e \u0433\u043e\u0442\u043e\u0432\u044b \u043a \u0434\u0438\u0441\u043a\u0443<\/p>\n<\/li>\n<li>\n<p><strong>\u0414\u0443\u0431\u043b\u0438\u043a\u0430\u0442\u044b \u043d\u0435\u0438\u0437\u0431\u0435\u0436\u043d\u044b.<\/strong> \u041f\u0440\u043e\u0435\u043a\u0442\u0438\u0440\u0443\u0439\u0442\u0435 <strong>\u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e<\/strong> (\u043d\u0430\u0442\u0443\u0440\u0430\u043b\u044c\u043d\u044b\u0435 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 \/ UPSERT, \u043a\u043b\u044e\u0447\u0438, registry processed ids)<\/p>\n<\/li>\n<li>\n<p><strong>\u041e\u0434\u0438\u043d \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044c RabbitMQ \u0434\u043b\u044f \u0432\u0441\u0435\u0445 \u0441\u0435\u0440\u0432\u0438\u0441\u043e\u0432<\/strong> \u2013 \u043f\u043b\u043e\u0445\u043e: \u043b\u0438\u0448\u0430\u0435\u0442 \u0432\u0438\u0434\u0438\u043c\u043e\u0441\u0442\u0438 \u0438 \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044f. \u0414\u0435\u043b\u0438\u0442\u0435 \u0434\u043e\u0441\u0442\u0443\u043f\u044b<\/p>\n<\/li>\n<li>\n<p><strong>guest \/ guest \u0432 \u043f\u0440\u043e\u0434\u0435<\/strong> \u2013 \u043d\u0438\u043a\u043e\u0433\u0434\u0430<\/p>\n<\/li>\n<li>\n<p><strong>prefetch \u043f\u043e \u0443\u043c\u043e\u043b\u0447\u0430\u043d\u0438\u044e<\/strong> \u0434\u0443\u0448\u0438\u0442 \u043b\u0430\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c: \u043f\u043e\u0434\u0431\u0435\u0440\u0438\u0442\u0435 <code>set_qos<\/code> \u044d\u043a\u0441\u043f\u0435\u0440\u0438\u043c\u0435\u043d\u0442\u0430\u043b\u044c\u043d\u043e (\u043e\u0431\u044b\u0447\u043d\u043e 16\u2013256)<\/p>\n<\/li>\n<li>\n<p><strong>\u041d\u0435\u0442 AE \/ mandatory<\/strong> \u2013 \u00ab\u0447\u0451\u0440\u043d\u0430\u044f \u0434\u044b\u0440\u0430\u00bb<\/p>\n<\/li>\n<li>\n<p><strong>\u041d\u0435\u0442 DLX<\/strong> \u2013 \u00ab\u044f\u0434\u043e\u0432\u0438\u0442\u044b\u0435\u00bb \u043a\u0440\u0443\u0442\u044f\u0442\u0441\u044f \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u043e<\/p>\n<\/li>\n<\/ul>\n<h3>\u0427\u0435\u043a-\u043b\u0438\u0441\u0442 \u0432\u043d\u0435\u0434\u0440\u0435\u043d\u0438\u044f<\/h3>\n<ol>\n<li>\n<p>\u0412\u043a\u043b\u044e\u0447\u0438\u0442\u044c <strong>Transactional Outbox<\/strong> \u0432 \u0441\u0435\u0440\u0432\u0438\u0441\u0430\u0445-\u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430\u0445<\/p>\n<\/li>\n<li>\n<p>\u041f\u0443\u0431\u043b\u0438\u043a\u043e\u0432\u0430\u0442\u044c \u0441 <strong>publisher confirms<\/strong> + <code>mandatory=true<\/code>, \u043d\u0430\u0441\u0442\u0440\u043e\u0438\u0442\u044c <strong>AE<\/strong><\/p>\n<\/li>\n<li>\n<p>\u0414\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0439 \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e\u0439 \u043b\u0438\u043d\u0438\u0438 \u2013 \u0441\u0432\u043e\u044f \u043e\u0447\u0435\u0440\u0435\u0434\u044c, \u0434\u043b\u044f \u0444\u043e\u043d\u043e\u0432\u043e\u0439 \u2013 TTL \/ \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d\u0438\u044f<\/p>\n<\/li>\n<li>\n<p>\u041f\u043e\u0434\u043f\u0438\u0441\u0447\u0438\u043a\u0438: <strong>\u0440\u0443\u0447\u043d\u044b\u0435 ack \/ nack<\/strong>, DLX, \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c<\/p>\n<\/li>\n<li>\n<p>\u041d\u0430\u0441\u0442\u0440\u043e\u0438\u0442\u044c <code>prefetch<\/code>, health-\u043f\u0440\u043e\u0431\u044b, \u0430\u0432\u0442\u043e-reconnect<\/p>\n<\/li>\n<li>\n<p>\u041c\u0435\u0442\u0440\u0438\u043a\u0438: ready \/ unacked, publish \/ ack rate, \u0433\u043b\u0443\u0431\u0438\u043d\u0430 DLQ, x-death<\/p>\n<\/li>\n<li>\n<p>Runbook: \u043a\u0430\u043a \u0447\u0438\u0441\u0442\u0438\u0442\u044c DLQ, \u043a\u0430\u043a \u00ab\u0440\u0435-\u043f\u0440\u043e\u0438\u0433\u0440\u044b\u0432\u0430\u0442\u044c\u00bb \u0438\u0437 \u043f\u0430\u0440\u043a\u043e\u0432\u043a\u0438<\/p>\n<\/li>\n<\/ol>\n<h3>\u0418\u0442\u043e\u0433<\/h3>\n<p>RabbitMQ \u0441\u0430\u043c \u043f\u043e \u0441\u0435\u0431\u0435 \u043d\u0435 \u00ab\u043b\u0435\u0447\u0438\u0442\u00bb \u0441\u0438\u0441\u0442\u0435\u043c\u0443. \u041d\u043e \u0441 \u043f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e\u0439 \u0442\u043e\u043f\u043e\u043b\u043e\u0433\u0438\u0435\u0439 (Outbox \u2013 Confirms + AE \u2013 Idempotent Consumers + DLX \u2013 \u041a\u043e\u043d\u0442\u0440\u043e\u043b\u044c \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438) \u0432\u044b \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442\u0435 <strong>\u043a\u043e\u043d\u0442\u0440\u043e\u043b\u0438\u0440\u0443\u0435\u043c\u0443\u044e \u0434\u0435\u0433\u0440\u0430\u0434\u0430\u0446\u0438\u044e<\/strong>: \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u044b\u0435 \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u043f\u0440\u0438\u0445\u043e\u0434\u044f\u0442, \u0444\u043e\u043d\u043e\u0432\u044b\u0435 \u043e\u0442\u0432\u0430\u043b\u0438\u0432\u0430\u044e\u0442\u0441\u044f \u043f\u0435\u0440\u0432\u044b\u043c\u0438, \u00ab\u044f\u0434\u043e\u0432\u0438\u0442\u044b\u0435\u00bb \u0431\u0435\u0437\u043e\u043f\u0430\u0441\u043d\u043e \u043f\u0430\u0440\u043a\u0443\u044e\u0442\u0441\u044f, \u0430 \u0434\u0430\u043d\u043d\u044b\u0435 \u2013 \u043d\u0435 \u0442\u0435\u0440\u044f\u044e\u0442\u0441\u044f. \u042d\u0442\u043e \u0438 \u0435\u0441\u0442\u044c \u00ab\u0447\u0435\u0441\u0442\u043d\u0430\u044f\u00bb \u043e\u0442\u043a\u0430\u0437\u043e\u0443\u0441\u0442\u043e\u0439\u0447\u0438\u0432\u043e\u0441\u0442\u044c \u0432 \u0440\u0435\u0430\u043b\u044c\u043d\u043e\u0439 \u0436\u0438\u0437\u043d\u0438<\/p>\n<\/div>\n<\/div>\n<\/div>\n<p><!----><!----><\/div>\n<p><!----><!----><br \/> \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u0441\u0442\u0430\u0442\u044c\u0438 <a href=\"https:\/\/habr.com\/ru\/articles\/943022\/\"> https:\/\/habr.com\/ru\/articles\/943022\/<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"<div><!--[--><!--]--><\/div>\n<div id=\"post-content-body\">\n<div>\n<div class=\"article-formatted-body article-formatted-body article-formatted-body_version-2\">\n<div xmlns=\"http:\/\/www.w3.org\/1999\/xhtml\">\n<p>\u041f\u0440\u0430\u043a\u0442\u0438\u043a\u0430 outbox, \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0438 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438, DLX \u0438 \u0441\u0445\u0435\u043c\u044b, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0440\u0435\u0430\u043b\u044c\u043d\u043e \u0441\u043f\u0430\u0441\u0430\u044e\u0442 \u043f\u0440\u043e\u0434<\/p>\n<p><strong>\u0421\u0438\u0442\u0443\u0430\u0446\u0438\u044f.<\/strong> REST-\u0432\u044b\u0437\u043e\u0432\u044b \u043c\u0435\u0436\u0434\u0443 \u0441\u0435\u0440\u0432\u0438\u0441\u0430\u043c\u0438 \u043d\u0430\u0447\u0430\u043b\u0438 \u0432\u0430\u043b\u0438\u0442\u044c \u0434\u0440\u0443\u0433 \u0434\u0440\u0443\u0433\u0430: \u0446\u0435\u043f\u043e\u0447\u043a\u0438 \u0437\u0430\u043f\u0440\u043e\u0441\u043e\u0432, \u0442\u0430\u0439\u043c\u0430\u0443\u0442\u044b, \u043a\u0430\u0441\u043a\u0430\u0434\u043d\u044b\u0435 \u0444\u0435\u0439\u043b\u044b. \u041c\u044b \u043f\u0435\u0440\u0435\u0432\u0435\u043b\u0438 \u043a\u043e\u043c\u043c\u0443\u043d\u0438\u043a\u0430\u0446\u0438\u044e \u043d\u0430 RabbitMQ \u2013 \u0438 \u0434\u043e\u0431\u0438\u043b\u0438\u0441\u044c \u043d\u0435 \u00ab\u0431\u0435\u0437\u043e\u0448\u0438\u0431\u043e\u0447\u043d\u043e\u0441\u0442\u0438\u00bb, \u0430 <strong>\u043f\u0440\u0435\u0434\u0441\u043a\u0430\u0437\u0443\u0435\u043c\u043e\u0439 \u0434\u0435\u0433\u0440\u0430\u0434\u0430\u0446\u0438\u0438<\/strong>: \u0434\u0430\u043d\u043d\u044b\u0435 \u043d\u0435 \u0442\u0435\u0440\u044f\u044e\u0442\u0441\u044f, \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e\u0435 \u2013 \u0435\u0434\u0435\u0442 \u043f\u0435\u0440\u0432\u044b\u043c, \u044f\u0434 \u0431\u044b\u0441\u0442\u0440\u0435\u0435 \u0432\u043e\u0441\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u0435\u0442\u0441\u044f<\/p>\n<p>\u041d\u0438\u0436\u0435 \u2013 \u0442\u043e\u043b\u044c\u043a\u043e \u043f\u0440\u0438\u043a\u043b\u0430\u0434\u043d\u043e\u0435: \u043f\u0440\u043e\u0432\u0435\u0440\u0435\u043d\u043d\u044b\u0435 \u043f\u0430\u0442\u0442\u0435\u0440\u043d\u044b, \u0433\u043e\u0442\u043e\u0432\u044b\u0435 \u0444\u0440\u0430\u0433\u043c\u0435\u043d\u0442\u044b \u043a\u043e\u0434\u0430 (Python \/ aio-pika), \u0438 \u0441\u0445\u0435\u043c\u044b, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043c\u043e\u0436\u043d\u043e \u0441\u0440\u0430\u0437\u0443 \u0432\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u0442\u044c<\/p>\n<h3>\u0411\u0430\u0437\u0430: \u00ab\u0434\u0435\u0433\u0440\u0430\u0434\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441 \u0447\u0435\u0441\u0442\u044c\u044e\u00bb \u2013 \u044d\u0442\u043e \u043a\u0430\u043a?<\/h3>\n<p>\u041f\u0440\u0438\u043d\u0446\u0438\u043f \u043f\u0440\u043e\u0441\u0442\u043e\u0439: \u0435\u0441\u043b\u0438 \u0431\u0440\u043e\u043a\u0435\u0440, \u043f\u043e\u0442\u0440\u0435\u0431\u0438\u0442\u0435\u043b\u0438 \u0438\u043b\u0438 \u0441\u0435\u0442\u044c \u00ab\u0441\u044b\u043f\u044f\u0442\u0441\u044f\u00bb, <strong>\u0441\u0438\u0441\u0442\u0435\u043c\u0430 \u043d\u0435 \u043b\u043e\u043c\u0430\u0435\u0442 \u0431\u0438\u0437\u043d\u0435\u0441-\u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 \u0438 \u043d\u0435 \u0442\u0435\u0440\u044f\u0435\u0442 \u0441\u043e\u0431\u044b\u0442\u0438\u0439<\/strong>, \u0430:<\/p>\n<ul>\n<li>\n<p>\u0412\u0440\u0435\u043c\u0435\u043d\u043d\u043e <strong>\u0431\u0443\u0444\u0435\u0440\u0438\u0437\u0443\u0435\u0442<\/strong><\/p>\n<\/li>\n<li>\n<p><strong>\u0420\u0430\u0441\u0441\u0442\u0430\u0432\u043b\u044f\u0435\u0442 \u043f\u0440\u0438\u043e\u0440\u0438\u0442\u0435\u0442\u044b<\/strong><\/p>\n<\/li>\n<li>\n<p><strong>\u041e\u0442\u0431\u0438\u0432\u0430\u0435\u0442 \u044f\u0434<\/strong> \u043e\u0442 \u00ab\u044f\u0434\u043e\u0432\u0438\u0442\u044b\u0445\u00bb \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439<\/p>\n<\/li>\n<li>\n<p>\u0412<strong>\u043e\u0441\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u0435\u0442\u0441\u044f<\/strong> \u0434\u043e \u0441\u043e\u0433\u043b\u0430\u0441\u043e\u0432\u0430\u043d\u043d\u043e\u0433\u043e \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u044f<\/p>\n<\/li>\n<\/ul>\n<p>\u0412 RabbitMQ \u044d\u0442\u043e \u0441\u043e\u0431\u0438\u0440\u0430\u0435\u0442\u0441\u044f \u0438\u0437 \u0447\u0435\u0442\u044b\u0440\u0451\u0445 \u043a\u0438\u0440\u043f\u0438\u0447\u0435\u0439:<\/p>\n<ol>\n<li>\n<p><strong>Transactional Outbox<\/strong> (\u0441\u043e\u0431\u044b\u0442\u0438\u044f \u0432 \u0441\u0432\u043e\u0435\u0439 \u0411\u0414 \u0434\u043e \u0431\u0440\u043e\u043a\u0435\u0440\u0430)<\/p>\n<\/li>\n<li>\n<p><strong>\u0411\u0435\u0437\u043e\u043f\u0430\u0441\u043d\u0430\u044f \u043f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u044f<\/strong> (publisher confirms + mandatory \/ AE)<\/p>\n<\/li>\n<li>\n<p><strong>\u0411\u0435\u0437\u043e\u043f\u0430\u0441\u043d\u043e\u0435 \u043f\u043e\u0442\u0440\u0435\u0431\u043b\u0435\u043d\u0438\u0435<\/strong> (\u0440\u0443\u0447\u043d\u044b\u0435 ack \/ nack, DLX, \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c)<\/p>\n<\/li>\n<li>\n<p><strong>\u041a\u043e\u043d\u0442\u0440\u043e\u043b\u044c \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438<\/strong> (prefetch, TTL, max-length, \u043f\u0440\u0438\u043e\u0440\u0438\u0442\u0435\u0442\u044b \/ \u0440\u0430\u0437\u0434\u0435\u043b\u0435\u043d\u0438\u0435 \u043e\u0447\u0435\u0440\u0435\u0434\u0435\u0439)<\/p>\n<\/li>\n<\/ol>\n<h3>\u0428\u0430\u0433 1. Transactional Outbox \u2013 \u043d\u0438\u043a\u0430\u043a\u0438\u0445 \u043f\u043e\u0442\u0435\u0440\u044c \u043f\u0440\u0438 \u043f\u0430\u0434\u0435\u043d\u0438\u0438 \u0431\u0440\u043e\u043a\u0435\u0440\u0430<\/h3>\n<p>\u0421\u0443\u0442\u044c: \u0432\u043c\u0435\u0441\u0442\u0435 \u0441 \u0437\u0430\u043f\u0438\u0441\u044c\u044e \u0431\u0438\u0437\u043d\u0435\u0441-\u0441\u043e\u0431\u044b\u0442\u0438\u044f \u043f\u0438\u0448\u0435\u043c \u0441\u0442\u0440\u043e\u043a\u0443 \u0432 <code>outbox<\/code> \u0432 <strong>\u0442\u043e\u0439 \u0436\u0435 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438<\/strong>. \u0424\u043e\u043d\u043e\u0432\u044b\u0439 \u0432\u043e\u0440\u043a\u0435\u0440 \u043f\u0443\u0431\u043b\u0438\u043a\u0443\u0435\u0442 \u0432 RabbitMQ \u0441 \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u044f\u043c\u0438; \u043f\u0440\u0438 \u0441\u0431\u043e\u044f\u0445 \u2013 \u0440\u0435\u0442\u0440\u0430\u0438\u0442. \u0421\u043e\u0431\u044b\u0442\u0438\u0435 \u043d\u0435 \u00ab\u0438\u0441\u0447\u0435\u0437\u043d\u0435\u0442\u00bb \u043c\u0435\u0436\u0434\u0443 \u0411\u0414 \u0438 \u0431\u0440\u043e\u043a\u0435\u0440\u043e\u043c<\/p>\n<figure class=\"full-width\">\n<div><figcaption>\u0410\u0440\u0445\u0438\u0442\u0435\u043a\u0442\u0443\u0440\u0430 \u0441 Outbox, AE \u0438 DLX<\/figcaption><\/div>\n<\/figure>\n<p><strong>DDL (PostgreSQL):<\/strong><\/p>\n<pre><code class=\"python\">create table outbox (   id            uuid primary key,   aggregate     text not null,   event_type    text not null,   payload       jsonb not null,   created_at    timestamptz not null default now(),   status        text not null default 'NEW',      -- NEW|SENT|FAILED   attempts      int  not null default 0,   next_retry_at timestamptz );  create index on outbox (status, next_retry_at);<\/code><\/pre>\n<p><strong>\u0412\u043e\u0440\u043a\u0435\u0440 \u043f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u0438 (Python, aio-pika, \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u044f + mandatory):<\/strong><\/p>\n<pre><code class=\"python\">import asyncio, json, uuid, asyncpg from aio_pika import connect_robust, Message, DeliveryMode, RobustConnection, RobustChannel, ExchangeType from datetime import datetime, timedelta  AMQP_URL = \"amqp:\/\/user:pass@rabbit:5672\/%2F\" EXCHANGE = \"events.topic\"  async def publish_outbox_batch(pool):     conn: RobustConnection = await connect_robust(AMQP_URL)     ch: RobustChannel = await conn.channel(publisher_confirms=True)     exchange = await ch.declare_exchange(EXCHANGE, ExchangeType.TOPIC, durable=True,                                          arguments={\"alternate-exchange\": \"events.ae\"})  # AE \u043d\u0430 \u0441\u043b\u0443\u0447\u0430\u0439 unroutable     while True:         async with pool.acquire() as db:             rows = await db.fetch(\"\"\"               update outbox                  set status='IN_PROGRESS'                where id in (                  select id from outbox                   where status='NEW'                      or (status='FAILED' and (next_retry_at is null or next_retry_at &lt;= now()))                   order by created_at                   limit 200                )              returning id, event_type, payload             \"\"\")         if not rows:             await asyncio.sleep(0.3)             continue          to_ack, to_fail = [], []         for r in rows:             body = json.dumps(r[\"payload\"]).encode()             msg = Message(                 body,                 delivery_mode=DeliveryMode.PERSISTENT,                 message_id=str(uuid.uuid4()),                 content_type=\"application\/json\",                 headers={\"event_type\": r[\"event_type\"]},             )             routing_key = f\"{r['event_type']}\"             try:                 # mandatory=True - UnroutableError, \u0435\u0441\u043b\u0438 \u043d\u0435\u043a\u0443\u0434\u0430 \u0434\u043e\u0441\u0442\u0430\u0432\u0438\u0442\u044c                 await exchange.publish(msg, routing_key=routing_key, mandatory=True)                 to_ack.append(r[\"id\"])             except Exception:                 to_fail.append(r[\"id\"])          async with pool.acquire() as db:             if to_ack:                 await db.execute(\"update outbox set status='SENT' where id = any($1)\", to_ack)             if to_fail:                 await db.execute(\"\"\"                   update outbox                      set status='FAILED',                          attempts = attempts + 1,                          next_retry_at = now() + ((least(attempts, 10)) * interval '10 seconds')                    where id = any($1)                 \"\"\", to_fail)  async def main():     pool = await asyncpg.create_pool(dsn=\"postgres:\/\/user:pass@db\/app\")     await publish_outbox_batch(pool)  asyncio.run(main())<\/code><\/pre>\n<p><strong>\u0427\u0442\u043e \u0432\u0430\u0436\u043d\u043e:<\/strong><\/p>\n<ul>\n<li>\n<p><code>publisher_confirms=True<\/code> \u2013 \u0436\u0434\u0451\u043c \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u0435 \u0431\u0440\u043e\u043a\u0435\u0440\u0430<\/p>\n<\/li>\n<li>\n<p><code>mandatory=True<\/code> + <strong>alternate-exchange<\/strong> (AE) \u2013 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0440\u0443\u0435\u043c, \u0447\u0442\u043e <strong>\u043d\u0438 \u043e\u0434\u043d\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043d\u0435 \u0443\u0439\u0434\u0451\u0442 \u0432 \u00ab\u0432\u0430\u043a\u0443\u0443\u043c\u00bb<\/strong><\/p>\n<\/li>\n<li>\n<p>\u042d\u043a\u0441\u043f\u043e\u043d\u0435\u043d\u0446\u0438\u0430\u043b\u044c\u043d\u044b\u0439 backoff \u043f\u043e <code>attempts<\/code> \u2013 <strong>\u043d\u0435 \u0434\u0443\u0448\u0438\u043c<\/strong> \u0431\u0440\u043e\u043a\u0435\u0440 \u043f\u0440\u0438 \u0432\u043e\u0441\u0441\u0442\u0430\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u0438<\/p>\n<\/li>\n<\/ul>\n<h3>\u0428\u0430\u0433 2. \u041f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u044f \u0441 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u044f\u043c\u0438: confirms, mandatory, AE<\/h3>\n<ul>\n<li>\n<p><strong>Publisher Confirms<\/strong>: \u0431\u0440\u043e\u043a\u0435\u0440 \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0430\u0435\u0442 \u043f\u0440\u0438\u0451\u043c (\u043f\u0435\u0440-\u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438\u043b\u0438 \u0431\u0430\u0442\u0447\u0435\u043c)<\/p>\n<\/li>\n<li>\n<p><strong>mandatory<\/strong>: \u0435\u0441\u043b\u0438 \u043d\u0438 \u043e\u0434\u043d\u0430 \u043f\u0440\u0438\u0432\u044f\u0437\u043a\u0430 \u043d\u0435 \u043f\u043e\u0434\u0445\u043e\u0434\u0438\u0442, \u0431\u0440\u043e\u043a\u0435\u0440 \u0432\u0435\u0440\u043d\u0451\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 (\u0438\u043b\u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442 \u0432 AE)<\/p>\n<\/li>\n<li>\n<p><strong>Alternate Exchange (AE)<\/strong>: \u0437\u0430\u043f\u0430\u0441\u043d\u043e\u0439 \u043e\u0431\u043c\u0435\u043d\u043d\u0438\u043a \u0434\u043b\u044f <strong>unroutable<\/strong> \u2013 \u0441\u043a\u043b\u0430\u0434\u044b\u0432\u0430\u0435\u043c \u0442\u0443\u0434\u0430 \u0438 \u0430\u043b\u0435\u0440\u0442\u0438\u043c<\/p>\n<\/li>\n<\/ul>\n<figure class=\"full-width\">\n<div><figcaption>\u041f\u043e\u0441\u043b\u0435\u0434\u043e\u0432\u0430\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c \u043f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u0438<strong> <\/strong><\/figcaption><\/div>\n<\/figure>\n<p><strong>\u0422\u043e\u043f\u043e\u043b\u043e\u0433\u0438\u044f (\u043e\u0431\u044a\u044f\u0432\u043b\u0435\u043d\u0438\u0435 \u043e\u0431\u043c\u0435\u043d\u043d\u0438\u043a\u043e\u0432 \u0438 AE):<\/strong><\/p>\n<pre><code class=\"python\"># \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u0439 \u043e\u0431\u043c\u0435\u043d\u043d\u0438\u043a \u0441\u043e\u0431\u044b\u0442\u0438\u0439 await ch.declare_exchange(\"events.topic\", ExchangeType.TOPIC, durable=True,                           arguments={\"alternate-exchange\": \"events.ae\"}) # AE \u0434\u043b\u044f \u043d\u0435 \u043c\u0430\u0440\u0448\u0440\u0443\u0442\u0438\u0437\u043e\u0432\u0430\u043d\u043d\u044b\u0445 await ch.declare_exchange(\"events.ae\", ExchangeType.FANOUT, durable=True) # \u043e\u0447\u0435\u0440\u0435\u0434\u044c-\u043f\u0430\u0440\u043a\u043e\u0432\u043a\u0430 \u0434\u043b\u044f unroutable q_ae = await ch.declare_queue(\"events.unroutable\", durable=True) await q_ae.bind(\"events.ae\", routing_key=\"\")<\/code><\/pre>\n<h3>\u0428\u0430\u0433 3. \u041f\u043e\u0442\u0440\u0435\u0431\u043b\u0435\u043d\u0438\u0435 \u0431\u0435\u0437 \u0441\u044e\u0440\u043f\u0440\u0438\u0437\u043e\u0432: ack \/ nack, DLX, \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c<\/h3>\n<p><strong>\u0426\u0435\u043b\u0438:<\/strong><\/p>\n<ul>\n<li>\n<p>\u041d\u0435 \u0442\u0435\u0440\u044f\u0435\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f<\/p>\n<\/li>\n<li>\n<p>\u041d\u0435 \u0437\u0430\u0446\u0438\u043a\u043b\u0438\u0432\u0430\u0435\u043c \u00ab\u044f\u0434\u043e\u0432\u0438\u0442\u044b\u0435\u00bb<\/p>\n<\/li>\n<li>\n<p>\u041e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u043c <strong>\u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e<\/strong> (\u0434\u0443\u0431\u043b\u0438\u043a\u0430\u0442\u044b \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u044b)<\/p>\n<\/li>\n<\/ul>\n<p><strong>\u041e\u0447\u0435\u0440\u0435\u0434\u044c \u0441 DLX \/ TTL \/ \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d\u0438\u0435\u043c:<\/strong><\/p>\n<pre><code class=\"python\"># Dead-letter exchange await ch.declare_exchange(\"events.dlx\", ExchangeType.TOPIC, durable=True)  args = {     \"x-dead-letter-exchange\": \"events.dlx\",     \"x-dead-letter-routing-key\": \"dead.order\",   # \u0438\u043b\u0438 \u043f\u043e \u0448\u0430\u0431\u043b\u043e\u043d\u0443     \"x-message-ttl\": 10_000,                     # TTL \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0432 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 (\u043f\u0440\u0438\u043c\u0435\u0440)     \"x-max-length\": 50_000,                      # \u0437\u0430\u0449\u0438\u0442\u0438\u043c\u0441\u044f \u043e\u0442 \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u043e\u0433\u043e \u0440\u043e\u0441\u0442\u0430     \"x-queue-mode\": \"lazy\",                      # \u043a\u0440\u0443\u043f\u043d\u044b\u0435 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 - \u043d\u0430 \u0434\u0438\u0441\u043a     \"x-max-priority\": 10,                        # \u0435\u0441\u043b\u0438 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0435 \u043f\u0440\u0438\u043e\u0440\u0438\u0442\u0435\u0442\u044b }  q = await ch.declare_queue(\"order.events\", durable=True, arguments=args) await q.bind(\"events.topic\", routing_key=\"order.*\")<\/code><\/pre>\n<p><strong>\u0418\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u044b\u0439 consumer (\u0441 \u0443\u0447\u0451\u0442\u043e\u043c \u0434\u0443\u0431\u043b\u0438\u043a\u0430\u0442\u043e\u0432 \u0438 \u00ab\u044f\u0434\u043e\u0432\u0438\u0442\u044b\u0445\u00bb): <\/strong>\u043a\u0430\u043a \u043d\u0435 \u043f\u043e\u0442\u0435\u0440\u044f\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043f\u0440\u0438 \u0441\u0431\u043e\u0435<\/p>\n<pre><code class=\"python\">import hashlib, aioredis  redis = await aioredis.from_url(\"redis:\/\/redis:6379\/0\")  def seen_key(message_id: str) -&gt; str:     return f\"seen:{message_id}\"  async def handle(message):     # \u0431\u0438\u0437\u043d\u0435\u0441-\u043b\u043e\u0433\u0438\u043a\u0430     ...  async def consume(message):     async with message.process(ignore_processed=True):  # manual ack \/ nack \u0432\u043d\u0443\u0442\u0440\u0438 \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u0430         mid = message.message_id or hashlib.sha1(message.body).hexdigest()          # \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c: \u0443\u0436\u0435 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u043b\u0438?         if await redis.setnx(seen_key(mid), \"1\"):             await redis.expire(seen_key(mid), 24*3600)  # \u0445\u0440\u0430\u043d\u0438\u0442\u044c \u0441\u0443\u0442\u043a\u0438 \/ \u043d\u0435\u0434\u0435\u043b\u044e - \u043f\u043e \u043e\u0431\u044a\u0451\u043c\u0443             try:                 await handle(message)                 # ack \u043f\u0440\u043e\u0438\u0437\u043e\u0439\u0434\u0451\u0442 \u043f\u0440\u0438 \u0432\u044b\u0445\u043e\u0434\u0435 \u0438\u0437 \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u0430             except TransientError:                 # \u0432\u0440\u0435\u043c\u0435\u043d\u043d\u0430\u044f \u043e\u0448\u0438\u0431\u043a\u0430 - \u0432\u0435\u0440\u043d\u0451\u043c \u0432 \u043e\u0447\u0435\u0440\u0435\u0434\u044c (\u0441 \u0443\u0447\u0451\u0442\u043e\u043c TTL \/ DLX \/ \u043f\u043e\u0432\u0442\u043e\u0440\u043d\u044b\u0445 \u043f\u043e\u043f\u044b\u0442\u043e\u043a)                 await message.nack(requeue=True)             except Exception:                 # \u044f\u0434 - \u0432 DLX, \u0447\u0442\u043e\u0431\u044b \u043d\u0435 \u043a\u0440\u0443\u0442\u0438\u0442\u044c \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u043e                 await message.reject(requeue=False)         else:             # \u0434\u0443\u0431\u043b\u0438\u043a\u0430\u0442 - \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0430\u0435\u043c \u0442\u0438\u0445\u043e             return  await q.consume(consume, no_ack=False) await ch.set_qos(prefetch_count=64)  # \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044c \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438<\/code><\/pre>\n<p><strong>\u0417\u0430\u0447\u0435\u043c DLX:<\/strong> \u00ab\u044f\u0434\u043e\u0432\u0438\u0442\u044b\u0435\u00bb \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u043f\u043e\u043f\u0430\u0434\u0430\u044e\u0442 \u0432 \u00ab\u043a\u043b\u0430\u0434\u0431\u0438\u0449\u0435\u00bb (parking lot). \u0422\u0430\u043c \u0438\u0445 \u043c\u043e\u0436\u043d\u043e \u0440\u0443\u043a\u0430\u043c\u0438 \u0440\u0430\u0437\u0431\u0438\u0440\u0430\u0442\u044c \u0438\u043b\u0438 \u043f\u0435\u0440\u0435\u0438\u0433\u0440\u044b\u0432\u0430\u0442\u044c \u0447\u0435\u0440\u0435\u0437 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0439 \u00ab\u0440\u0435-\u043f\u0440\u043e\u0446\u0435\u0441\u0441\u043e\u0440\u00bb<\/p>\n<figure class=\"full-width\">\n<div><figcaption>\u041f\u043e\u0442\u0440\u0435\u0431\u043b\u0435\u043d\u0438\u0435 \u0441 \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c\u044e \u0438 DLX<\/figcaption><\/div>\n<\/figure>\n<h3>\u0428\u0430\u0433 4. \u041f\u0440\u0438\u043e\u0440\u0438\u0442\u0435\u0442\u044b \u0438 \u0440\u0430\u0437\u0434\u0435\u043b\u0435\u043d\u0438\u0435 \u043f\u0443\u0442\u0435\u0439: \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e\u0435 \u0435\u0434\u0435\u0442 \u043f\u0435\u0440\u0432\u044b\u043c<\/h3>\n<p>\u0427\u0430\u0441\u0442\u0430\u044f \u043e\u0448\u0438\u0431\u043a\u0430 \u2013 \u00ab\u043e\u0434\u043d\u0430 \u043e\u0447\u0435\u0440\u0435\u0434\u044c \u043d\u0430 \u0432\u0441\u0451\u00bb. \u0412 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u0435 \u0443\u0432\u0435\u0434\u043e\u043c\u043b\u0435\u043d\u0438\u044f \u0437\u0430\u0431\u0438\u0432\u0430\u044e\u0442 \u043f\u043e\u043b\u043e\u0441\u0443, \u0430 \u0434\u0435\u043d\u044c\u0433\u0438 \/ \u0437\u0430\u043a\u0430\u0437\u044b \u0436\u0434\u0443\u0442<\/p>\n<p><strong>\u041f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e:<\/strong><\/p>\n<ul>\n<li>\n<p>\u0420\u0430\u0437\u0434\u0435\u043b\u044f\u0435\u043c \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e\u0435 \u0438 \u0444\u043e\u043d\u043e\u0432\u043e\u0435 \u043f\u043e <strong>\u0440\u0430\u0437\u043d\u044b\u043c \u043e\u0447\u0435\u0440\u0435\u0434\u044f\u043c \/ \u043a\u043b\u044e\u0447\u0430\u043c<\/strong><\/p>\n<\/li>\n<li>\n<p>\u0414\u043b\u044f \u0444\u043e\u043d\u043e\u0432\u043e\u0433\u043e \u2013 <strong>TTL + max-length<\/strong> (\u0433\u043e\u0442\u043e\u0432\u044b \u0442\u0435\u0440\u044f\u0442\u044c \u00ab\u0445\u0432\u043e\u0441\u0442\u00bb \u043f\u0440\u0438 \u0430\u0432\u0430\u0440\u0438\u0438)<\/p>\n<\/li>\n<li>\n<p>\u0414\u043b\u044f \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e\u0433\u043e \u2013 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0435 \u0432\u043e\u0440\u043a\u0435\u0440\u044b \u0438 \u043c\u0435\u043d\u044c\u0448\u0438\u0439 prefetch (\u0431\u044b\u0441\u0442\u0440\u0435\u0435 \u0440\u0435\u0430\u043a\u0446\u0438\u044f)<\/p>\n<\/li>\n<\/ul>\n<p><strong>\u041f\u0440\u0438\u043c\u0435\u0440:<\/strong><\/p>\n<pre><code class=\"python\"># \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u0430\u044f \u043e\u0447\u0435\u0440\u0435\u0434\u044c (\u043e\u043f\u043b\u0430\u0442\u0430) await ch.declare_queue(\"billing.high\", durable=True,                        arguments={\"x-dead-letter-exchange\": \"events.dlx\"}) await ch.queue_bind(\"billing.high\", \"events.topic\", routing_key=\"billing.*\")  # \u0444\u043e\u043d\u043e\u0432\u0430\u044f (email): TTL + max-length, \u043f\u0443\u0441\u0442\u044c \u0434\u0435\u0433\u0440\u0430\u0434\u0438\u0440\u0443\u0435\u0442 \u043f\u0435\u0440\u0432\u043e\u0439 await ch.declare_queue(\"notify.low\", durable=True,   arguments={     \"x-dead-letter-exchange\": \"events.dlx\",     \"x-message-ttl\": 60_000,     \"x-max-length\": 20_000 }) await ch.queue_bind(\"notify.low\", \"events.topic\", routing_key=\"notify.*\")<\/code><\/pre>\n<h3>\u041d\u0430\u0431\u043e\u0440 \u00ab\u0433\u0440\u0430\u0431\u043b\u0435\u0439\u00bb \u0438 \u043a\u0430\u043a \u043c\u044b \u0438\u0445 \u043e\u0431\u0445\u043e\u0434\u0438\u043b\u0438<\/h3>\n<ul>\n<li>\n<p><strong>\u0411\u043e\u043b\u044c\u0448\u0438\u0435 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 = \u0430\u043d\u0442\u0438\u043f\u0430\u0442\u0442\u0435\u0440\u043d.<\/strong> \u0414\u0435\u043b\u0430\u0439\u0442\u0435 \u043a\u043e\u0440\u043e\u0442\u043a\u0438\u043c\u0438: <code>x-message-ttl<\/code>, <code>x-max-length<\/code>, \u00ab\u043b\u0435\u043d\u0438\u0432\u044b\u0435\u00bb (<code>x-queue-mode=lazy<\/code>) \u0442\u043e\u043b\u044c\u043a\u043e \u0442\u0430\u043c, \u0433\u0434\u0435 \u043e\u0441\u043e\u0437\u043d\u0430\u043d\u043d\u043e \u0433\u043e\u0442\u043e\u0432\u044b \u043a \u0434\u0438\u0441\u043a\u0443<\/p>\n<\/li>\n<li>\n<p><strong>\u0414\u0443\u0431\u043b\u0438\u043a\u0430\u0442\u044b \u043d\u0435\u0438\u0437\u0431\u0435\u0436\u043d\u044b.<\/strong> \u041f\u0440\u043e\u0435\u043a\u0442\u0438\u0440\u0443\u0439\u0442\u0435 <strong>\u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e<\/strong> (\u043d\u0430\u0442\u0443\u0440\u0430\u043b\u044c\u043d\u044b\u0435 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 \/ UPSERT, \u043a\u043b\u044e\u0447\u0438, registry processed ids)<\/p>\n<\/li>\n<li>\n<p><strong>\u041e\u0434\u0438\u043d \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044c RabbitMQ \u0434\u043b\u044f \u0432\u0441\u0435\u0445 \u0441\u0435\u0440\u0432\u0438\u0441\u043e\u0432<\/strong> \u2013 \u043f\u043b\u043e\u0445\u043e: \u043b\u0438\u0448\u0430\u0435\u0442 \u0432\u0438\u0434\u0438\u043c\u043e\u0441\u0442\u0438 \u0438 \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044f. \u0414\u0435\u043b\u0438\u0442\u0435 \u0434\u043e\u0441\u0442\u0443\u043f\u044b<\/p>\n<\/li>\n<li>\n<p><strong>guest \/ guest \u0432 \u043f\u0440\u043e\u0434\u0435<\/strong> \u2013 \u043d\u0438\u043a\u043e\u0433\u0434\u0430<\/p>\n<\/li>\n<li>\n<p><strong>prefetch \u043f\u043e \u0443\u043c\u043e\u043b\u0447\u0430\u043d\u0438\u044e<\/strong> \u0434\u0443\u0448\u0438\u0442 \u043b\u0430\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c: \u043f\u043e\u0434\u0431\u0435\u0440\u0438\u0442\u0435 <code>set_qos<\/code> \u044d\u043a\u0441\u043f\u0435\u0440\u0438\u043c\u0435\u043d\u0442\u0430\u043b\u044c\u043d\u043e (\u043e\u0431\u044b\u0447\u043d\u043e 16\u2013256)<\/p>\n<\/li>\n<li>\n<p><strong>\u041d\u0435\u0442 AE \/ mandatory<\/strong> \u2013 \u00ab\u0447\u0451\u0440\u043d\u0430\u044f \u0434\u044b\u0440\u0430\u00bb<\/p>\n<\/li>\n<li>\n<p><strong>\u041d\u0435\u0442 DLX<\/strong> \u2013 \u00ab\u044f\u0434\u043e\u0432\u0438\u0442\u044b\u0435\u00bb \u043a\u0440\u0443\u0442\u044f\u0442\u0441\u044f \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u043e<\/p>\n<\/li>\n<\/ul>\n<h3>\u0427\u0435\u043a-\u043b\u0438\u0441\u0442 \u0432\u043d\u0435\u0434\u0440\u0435\u043d\u0438\u044f<\/h3>\n<ol>\n<li>\n<p>\u0412\u043a\u043b\u044e\u0447\u0438\u0442\u044c <strong>Transactional Outbox<\/strong> \u0432 \u0441\u0435\u0440\u0432\u0438\u0441\u0430\u0445-\u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430\u0445<\/p>\n<\/li>\n<li>\n<p>\u041f\u0443\u0431\u043b\u0438\u043a\u043e\u0432\u0430\u0442\u044c \u0441 <strong>publisher confirms<\/strong> + <code>mandatory=true<\/code>, \u043d\u0430\u0441\u0442\u0440\u043e\u0438\u0442\u044c <strong>AE<\/strong><\/p>\n<\/li>\n<li>\n<p>\u0414\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0439 \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e\u0439 \u043b\u0438\u043d\u0438\u0438 \u2013 \u0441\u0432\u043e\u044f \u043e\u0447\u0435\u0440\u0435\u0434\u044c, \u0434\u043b\u044f \u0444\u043e\u043d\u043e\u0432\u043e\u0439 \u2013 TTL \/ \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d\u0438\u044f<\/p>\n<\/li>\n<li>\n<p>\u041f\u043e\u0434\u043f\u0438\u0441\u0447\u0438\u043a\u0438: <strong>\u0440\u0443\u0447\u043d\u044b\u0435 ack \/ nack<\/strong>, DLX, \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c<\/p>\n<\/li>\n<li>\n<p>\u041d\u0430\u0441\u0442\u0440\u043e\u0438\u0442\u044c <code>prefetch<\/code>, health-\u043f\u0440\u043e\u0431\u044b, \u0430\u0432\u0442\u043e-reconnect<\/p>\n<\/li>\n<li>\n<p>\u041c\u0435\u0442\u0440\u0438\u043a\u0438: ready \/ unacked, publish \/ ack rate, \u0433\u043b\u0443\u0431\u0438\u043d\u0430 DLQ, x-death<\/p>\n<\/li>\n<li>\n<p>Runbook: \u043a\u0430\u043a \u0447\u0438\u0441\u0442\u0438\u0442\u044c DLQ, \u043a\u0430\u043a \u00ab\u0440\u0435-\u043f\u0440\u043e\u0438\u0433\u0440\u044b\u0432\u0430\u0442\u044c\u00bb \u0438\u0437 \u043f\u0430\u0440\u043a\u043e\u0432\u043a\u0438<\/p>\n<\/li>\n<\/ol>\n<h3>\u0418\u0442\u043e\u0433<\/h3>\n<p>RabbitMQ \u0441\u0430\u043c \u043f\u043e \u0441\u0435\u0431\u0435 \u043d\u0435 \u00ab\u043b\u0435\u0447\u0438\u0442\u00bb \u0441\u0438\u0441\u0442\u0435\u043c\u0443. \u041d\u043e \u0441 \u043f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e\u0439 \u0442\u043e\u043f\u043e\u043b\u043e\u0433\u0438\u0435\u0439 (Outbox \u2013 Confirms + AE \u2013 Idempotent Consumers + DLX \u2013 \u041a\u043e\u043d\u0442\u0440\u043e\u043b\u044c \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438) \u0432\u044b \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442\u0435 <strong>\u043a\u043e\u043d\u0442\u0440\u043e\u043b\u0438\u0440\u0443\u0435\u043c\u0443\u044e \u0434\u0435\u0433\u0440\u0430\u0434\u0430\u0446\u0438\u044e<\/strong>: \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u044b\u0435 \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u043f\u0440\u0438\u0445\u043e\u0434\u044f\u0442, \u0444\u043e\u043d\u043e\u0432\u044b\u0435<\/p>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[],"tags":[],"class_list":["post-473677","post","type-post","status-publish","format-standard","hentry"],"_links":{"self":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/473677","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=473677"}],"version-history":[{"count":0,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/473677\/revisions"}],"wp:attachment":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=473677"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=473677"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=473677"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}