{"id":478096,"date":"2026-04-30T10:58:52","date_gmt":"2026-04-30T10:58:52","guid":{"rendered":"https:\/\/savepearlharbor.com\/?p=478096"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=478096","title":{"rendered":"\u041a\u0430\u043a \u043c\u044b \u043f\u0435\u0440\u0435\u043f\u0438\u0441\u044b\u0432\u0430\u043b\u0438 \u043b\u043e\u0433\u0438\u043a\u0443 \u043e\u0447\u0435\u0440\u0435\u0434\u0435\u0439: Celery =&gt; aio-pika =&gt; FastStream"},"content":{"rendered":"<div xmlns=\"http:\/\/www.w3.org\/1999\/xhtml\">\n<p>\u041d\u0430\u0448 \u043f\u0443\u0442\u044c \u0430\u043a\u0442\u0438\u0432\u043d\u043e\u0439 \u0440\u0430\u0431\u043e\u0442\u044b \u0441 \u043e\u0447\u0435\u0440\u0435\u0434\u044f\u043c\u0438 RabbitMQ \u043d\u0430\u0447\u0430\u043b\u0441\u044f \u0441 \u043a\u043b\u0430\u0441\u0441\u0438\u0447\u0435\u0441\u043a\u043e\u0433\u043e Celery. \u041e\u0441\u043e\u0437\u043d\u0430\u0432 \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e\u0441\u0442\u044c \u043d\u0438\u0437\u043a\u043e\u0443\u0440\u043e\u0432\u043d\u0435\u0432\u043e\u0433\u043e \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044f \u0441\u0438\u0441\u0442\u0435\u043c\u044b, \u043f\u0440\u0438\u043d\u044f\u043b\u0438\u0441\u044c \u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u0441 aio-pika. \u041d\u043e \u0438 \u044d\u0442\u043e\u0442 \u0443\u0440\u043e\u0432\u0435\u043d\u044c \u0441\u043b\u0438\u0448\u043a\u043e\u043c \u043c\u0435\u0441\u0442\u0430\u043c\u0438 \u0441\u043b\u043e\u0436\u043d\u044b\u0439 (\u0434\u0430\u043b\u0435\u0435 \u0440\u0430\u0441\u0441\u043a\u0430\u0436\u0443 \u043f\u043e\u0447\u0435\u043c\u0443), \u0438 \u043d\u0430\u0448\u043b\u0438 \u043e\u0442\u043b\u0438\u0447\u043d\u043e\u0435 \u0440\u0435\u0448\u0435\u043d\u0438\u0435, \u043d\u0430 \u0442\u0435\u043a\u0443\u0449\u0438\u0439 \u043c\u043e\u043c\u0435\u043d\u0442, \u0432 \u043b\u0438\u0446\u0435 FastStream. \u0421\u0440\u0430\u0437\u0443 \u043e\u0441\u0442\u0430\u0432\u043b\u044e \u0442\u0430\u043a\u0443\u044e \u043f\u043e\u043c\u0435\u0442\u043a\u0443, \u0447\u0442\u043e \u043a\u0430\u0436\u0434\u044b\u0439 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442 \u043f\u043e\u0434\u0445\u043e\u0434\u0438\u0442 \u0434\u043b\u044f \u0440\u0435\u0448\u0435\u043d\u0438\u044f \u0441\u0432\u043e\u0435\u0439 \u0437\u0430\u0434\u0430\u0447\u0438. \u041c\u044b \u0431\u043e\u043b\u044c\u0448\u0435 \u0445\u043e\u0442\u0435\u043b\u0438 \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0430\u043a\u0446\u0435\u043d\u0442 \u043d\u0430 \u0443\u0434\u043e\u0431\u0441\u0442\u0432\u043e \u0438 \u0441\u043a\u043e\u0440\u043e\u0441\u0442\u044c \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u043e\u0442\u043d\u043e\u0441\u0438\u0442\u0435\u043b\u044c\u043d\u043e \u0437\u0430\u0442\u0440\u0430\u0447\u0438\u0432\u0430\u0435\u043c\u043e\u0433\u043e \u0432\u0440\u0435\u043c\u0435\u043d\u0438 \u043d\u0430 \u043c\u0438\u0433\u0440\u0430\u0446\u0438\u0438 \u0440\u0435\u0448\u0435\u043d\u0438\u0439. <\/p>\n<p><em>N.B.<\/em>: \u041a\u043e\u0434 \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e \u043f\u043e\u043a\u0430\u0436\u0435\u0442\u0441\u044f \u043d\u0435\u043e\u043f\u0442\u0438\u043c\u0430\u043b\u044c\u043d\u044b\u043c \u0438\u043b\u0438 \u0441\u0442\u0430\u0440\u044b\u043c. \u042d\u0442\u043e \u0432\u0441\u0451 \u043d\u0430\u0448 \u0434\u043e\u0440\u043e\u0433\u043e\u0439 \u041b\u0435\u0433\u0430\u0441\u0438.<\/p>\n<h3>\u041f\u043e\u0441\u0442\u0430\u043d\u043e\u0432\u043a\u0430 \u0437\u0430\u0434\u0430\u0447\u0438<\/h3>\n<p>\u041d\u0430\u0448\u0430 \u0441\u0438\u0441\u0442\u0435\u043c\u0430 \u043f\u043e\u0441\u0442\u0440\u043e\u0435\u043d\u0430 \u043d\u0430 \u043e\u0441\u043d\u043e\u0432\u0435 \u043c\u0438\u043a\u0440\u043e\u0441\u0435\u0440\u0432\u0438\u0441\u043e\u0432, \u0440\u0430\u0431\u043e\u0442\u0430\u044e\u0449\u0438\u0445 \u0441 RabbitMQ. \u0412\u043d\u0443\u0442\u0440\u0438 &#8212; \u043e\u0431\u044b\u0447\u043d\u044b\u0439 \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u043a\u043e\u0434 \u0434\u043b\u044f \u043f\u043e\u0445\u043e\u0434\u0430 \u043d\u0430 \u0432\u043d\u0435\u0448\u043d\u0438\u0435 API \u0438 \u0432 \u0411\u0414. <\/p>\n<p>\u0422\u0440\u0435\u0431\u043e\u0432\u0430\u043d\u0438\u044f: <\/p>\n<ul>\n<li>\n<p>\u041d\u0430\u0434\u0435\u0436\u043d\u044b\u0439 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0438\u043d\u0433 &#8212; \u044d\u0442\u043e \u0434\u043b\u044f \u043d\u0430\u0441 \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e, \u0447\u0442\u043e\u0431\u044b \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0448\u043b\u043e \u043f\u043e \u0432\u0441\u0435\u043c\u0443 \u0444\u043b\u043e\u0443 \u0438 \u043d\u0438\u0433\u0434\u0435 \u043d\u0435 \u043e\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u043b\u043e\u0441\u044c \u0431\u0435\u0437 \u043f\u0440\u0438\u0447\u0438\u043d. \u0415\u0441\u043b\u0438 \u043e\u0448\u0438\u0431\u043a\u0430 \u043f\u0430\u0434\u0430\u0435\u0442, \u0442\u043e \u044d\u0442\u043e \u0434\u043e\u043b\u0436\u043d\u043e \u043e\u0442\u0440\u0430\u0436\u0430\u0442\u044c\u0441\u044f \u0432 3 \u043c\u0435\u0441\u0442\u0430\u0445: \u0411\u0414, \u043b\u043e\u0433\u0438 \u0438 \u043c\u0435\u0442\u0440\u0438\u043a\u0438.<\/p>\n<\/li>\n<li>\n<p>\u0420\u0435\u0442\u0440\u0430\u0438 \u043f\u0440\u0438 \u043e\u0448\u0438\u0431\u043a\u0430\u0445 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438. <\/p>\n<\/li>\n<li>\n<p>\u0422\u0440\u0435\u0439\u0441\u0438\u043d\u0433 &#8212; \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u043a\u0430 OpenTelemetry. <\/p>\n<\/li>\n<li>\n<p>\u041c\u043e\u043d\u0438\u0442\u043e\u0440\u0438\u043d\u0433 \u0441\u0435\u0440\u0432\u0438\u0441\u0430 \u0447\u0435\u0440\u0435\u0437 healthcheck\u2019\u0438. <\/p>\n<\/li>\n<li>\n<p>Prometheus \u043c\u0435\u0442\u0440\u0438\u043a\u0438.<\/p>\n<\/li>\n<\/ul>\n<hr\/>\n<h3>\u0420\u0435\u0448\u0435\u043d\u0438\u0435 \u21161: Celery \u043a\u0430\u043a \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440<\/h3>\n<h4>\u041f\u043e\u0447\u0435\u043c\u0443 Celery<\/h4>\n<p>Celery \u2014 \u043a\u043b\u0430\u0441\u0441\u0438\u0447\u0435\u0441\u043a\u0438\u0439 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442 \u0434\u043b\u044f \u0444\u043e\u043d\u043e\u0432\u044b\u0445 \u0437\u0430\u0434\u0430\u0447, \u0437\u043d\u0430\u043a\u043e\u043c\u044b\u0439 \u0431\u043e\u043b\u044c\u0448\u0438\u043d\u0441\u0442\u0432\u0443 Python-\u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u043e\u0432. \u0418\u0437 \u043a\u043e\u0440\u043e\u0431\u043a\u0438: \u0434\u0435\u043a\u043b\u0430\u0440\u0430\u0442\u0438\u0432\u043d\u043e\u0435 \u043e\u043f\u0438\u0441\u0430\u043d\u0438\u0435 \u0437\u0430\u0434\u0430\u0447, \u0440\u0435\u0442\u0440\u0430\u0438 \u0441 \u044d\u043a\u0441\u043f\u043e\u043d\u0435\u043d\u0446\u0438\u0430\u043b\u044c\u043d\u043e\u0439 \u0437\u0430\u0434\u0435\u0440\u0436\u043a\u043e\u0439, \u0445\u0440\u0430\u043d\u0435\u043d\u0438\u0435 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u043e\u0432, \u043c\u043e\u043d\u0438\u0442\u043e\u0440\u0438\u043d\u0433 \u0447\u0435\u0440\u0435\u0437 Flower, \u0438\u043d\u0442\u0435\u0433\u0440\u0430\u0446\u0438\u0438 \u0441 \u0444\u0440\u0435\u0439\u043c\u0432\u043e\u0440\u043a\u0430\u043c\u0438. \u041b\u043e\u0433\u0438\u043a\u0430 \u043f\u0440\u043e\u0441\u0442\u0430: \u043f\u0438\u0448\u0435\u0448\u044c <code>@app.task<\/code>, \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u0448\u044c \u0432\u043e\u0440\u043a\u0435\u0440 \u2014 \u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0438\u0437 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 \u043d\u0430\u0447\u0438\u043d\u0430\u044e\u0442 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0442\u044c\u0441\u044f.<\/p>\n<h4>\u041a\u0430\u043a \u043c\u044b \u0435\u0433\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043b\u0438<\/h4>\n<p>\u041c\u044b \u043d\u0435 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u043b\u0438 \u0437\u0430\u0434\u0430\u0447\u0438 \u0438\u0437 \u043a\u043e\u0434\u0430 \u0432 \u0434\u0443\u0445\u0435 <code>my_task.delay()<\/code>, \u0430 \u043d\u0430\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u043b\u0438 Celery \u043d\u0430 \u043f\u0440\u043e\u0441\u043b\u0443\u0448\u0438\u0432\u0430\u043d\u0438\u0435 \u0432\u043d\u0435\u0448\u043d\u0435\u0439 \u043e\u0447\u0435\u0440\u0435\u0434\u0438, \u043a\u0443\u0434\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043f\u043e\u043f\u0430\u0434\u0430\u043b\u0438 \u043e\u0442 \u0434\u0440\u0443\u0433\u0438\u0445 \u0441\u0438\u0441\u0442\u0435\u043c. \u041f\u043e \u0441\u0443\u0442\u0438, Celery \u0432\u044b\u0441\u0442\u0443\u043f\u0430\u043b \u043a\u0430\u043a consumer: \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0430\u043b\u0441\u044f \u043a \u0431\u0440\u043e\u043a\u0435\u0440\u0443, \u0437\u0430\u0431\u0438\u0440\u0430\u043b \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u0434\u0435\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043b \u0438 \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u043b \u0432 \u043d\u0430\u0448\u0438 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u0438. \u041d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438 \u0432\u0440\u043e\u0434\u0435 <code>max_retries<\/code>, <code>default_retry_delay<\/code>, <code>countdown<\/code> \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u043b\u0438 \u0433\u0438\u0431\u043a\u043e \u0443\u043f\u0440\u0430\u0432\u043b\u044f\u0442\u044c \u043f\u043e\u0432\u0435\u0434\u0435\u043d\u0438\u0435\u043c \u043f\u0440\u0438 \u0441\u0431\u043e\u044f\u0445. \u0412\u0430\u0436\u043d\u043e \u0435\u0449\u0451 \u043f\u043e\u0434\u0441\u0432\u0435\u0442\u0438\u0442\u044c, \u0447\u0442\u043e \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442 \u0432\u0441\u0435\u0433\u0434\u0430 \u0438\u0433\u043d\u043e\u0440\u0438\u0440\u0443\u0435\u0442\u0441\u044f \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440\u0430 <code>ignore_result=True<\/code> \u043f\u043e\u0441\u043a\u043e\u043b\u044c\u043a\u0443 \u0432\u0441\u0435 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u044b \u0437\u0430\u043f\u0438\u0441\u044b\u0432\u0430\u044e\u0442\u0441\u044f \u0432 \u0411\u0414.<\/p>\n<p>\u041f\u0440\u0438\u043c\u0435\u0440 \u0438\u043d\u0438\u0446\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u0432\u043e\u0440\u043a\u0435\u0440\u0430:<\/p>\n<pre><code class=\"python\">def create_app(    name,    broker,    include,    backend=None,    task_queues=None,    liveness_probe=1,    update_period=60,    watcher_config={},):    # \u0421\u043e\u0437\u0434\u0430\u043d\u0438\u0435 \u0441\u0430\u043c\u043e \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435 + \u043d\u0430\u043b\u043e\u0436\u0435\u043d\u0438\u0435 \u0434\u043e\u043f\u043e\u043b\u043d\u0438\u0442\u0435\u043b\u044c\u043d\u044b\u0445 \u043a\u043e\u043d\u0444\u0438\u0433\u0443\u0440\u0430\u0446\u0438\u0438    app = Celery(name, broker=broker, include=include, backend=backend)    app.conf.update(        result_expires=120,    )    add_without_heartbeat_argument = Option(        (\"--without-heartbeat\",),        default=True,    )    app.user_options[\"worker\"].add(add_without_heartbeat_argument)    if task_queues is not None:        app.conf.task_queues = task_queues    if liveness_probe:        add_update_period_argument = Option(            (\"--update-period\",),            default=update_period,        )        HEARTBEAT_FILE.touch()        app.user_options[\"worker\"].add(add_update_period_argument)        # \u0414\u043e\u0431\u0430\u0432\u043b\u0435\u043d\u0438\u0435 \u043a\u0430\u0441\u0442\u043e\u043c\u043d\u043e\u0439 livenessProbe \u0434\u043b\u044f K8s        app.steps[\"worker\"].add(LivenessProbe)        # \u0438\u043d\u0438\u0446\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f \u0442\u0440\u0435\u0439\u0441\u0438\u043d\u0433\u0430    with_tracing = watcher_config.get(\"with_tracing\")    if with_tracing:        tracing_exporters = watcher_config.get(\"tracing_exporters\", ())        signals.worker_process_init.connect(            init_celery_tracing(app_name=name, tracing_exporters=tracing_exporters),            weak=False,        )    return app<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:87px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<h4>\u0421 \u0447\u0435\u043c \u0441\u0442\u043e\u043b\u043a\u043d\u0443\u043b\u0438\u0441\u044c<\/h4>\n<p>Celery \u043f\u0440\u043e\u0435\u043a\u0442\u0438\u0440\u043e\u0432\u0430\u043b\u0441\u044f \u043a\u0430\u043a \u0441\u0438\u0441\u0442\u0435\u043c\u0430 \u043f\u0435\u0440\u0435\u0434\u0430\u0447\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u043c\u0435\u0436\u0434\u0443 \u0441\u0438\u0441\u0442\u0435\u043c\u0430\u043c\u0438. \u0418\u0437-\u0437\u0430 \u0447\u0435\u0433\u043e \u0441\u0442\u043e\u043b\u043a\u043d\u0443\u043b\u0438\u0441\u044c \u0441\u043e \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0438\u043c\u0438 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0430\u043c\u0438:<\/p>\n<ul>\n<li>\n<p><strong>\u041f\u043e\u0442\u0440\u0435\u0431\u043b\u0435\u043d\u0438\u0435 \u043f\u0430\u043c\u044f\u0442\u0438<\/strong> \u2014 \u0438\u0437-\u0437\u0430 \u043e\u0431\u043e\u0440\u0430\u0447\u0438\u0432\u0430\u043d\u0438\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0432 \u043c\u0435\u0442\u0430\u0434\u0430\u043d\u043d\u044b\u0435 \u0438 \u0445\u0440\u0430\u043d\u0435\u043d\u0438\u044f \u0432\u043d\u0443\u0442\u0440\u0435\u043d\u043d\u0438\u0445 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440 Celery \u0440\u0430\u0441\u0445\u043e\u0434 \u043e\u043f\u0435\u0440\u0430\u0442\u0438\u0432\u043d\u043e\u0439 \u043f\u0430\u043c\u044f\u0442\u0438 \u0431\u044b\u0441\u0442\u0440\u043e \u0440\u043e\u0441 \u043f\u0440\u043e\u043f\u043e\u0440\u0446\u0438\u043e\u043d\u0430\u043b\u044c\u043d\u043e \u043f\u043e\u0442\u043e\u043a\u0443 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439. \u041f\u0440\u0438 \u0432\u044b\u0441\u043e\u043a\u043e\u043c \u0442\u0435\u043c\u043f\u0435 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0432\u043e\u0440\u043a\u0435\u0440 \u043d\u0430\u0447\u0438\u043d\u0430\u043b \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u0437\u043d\u0430\u0447\u0438\u0442\u0435\u043b\u044c\u043d\u043e \u0431\u043e\u043b\u044c\u0448\u0435 \u041e\u0417\u0423, \u0447\u0435\u043c \u0442\u0440\u0435\u0431\u043e\u0432\u0430\u043b\u043e\u0441\u044c \u0441\u0430\u043c\u043e\u0439 \u0431\u0438\u0437\u043d\u0435\u0441-\u043b\u043e\u0433\u0438\u043a\u0435, \u0447\u0442\u043e \u0432\u044b\u043d\u0443\u0436\u0434\u0430\u043b\u043e \u0432\u044b\u0434\u0435\u043b\u044f\u0442\u044c \u0438\u0437\u0431\u044b\u0442\u043e\u0447\u043d\u044b\u0435 \u0440\u0435\u0441\u0443\u0440\u0441\u044b.<\/p>\n<\/li>\n<li>\n<p><strong>\u0423\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u0438\u0435 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f\u043c\u0438 \u0438 heartbeat<\/strong> \u2014 Celery \u0441\u043a\u0440\u044b\u0432\u0430\u0435\u0442 \u043c\u043d\u043e\u0433\u0438\u0435 \u0434\u0435\u0442\u0430\u043b\u0438 \u0431\u0440\u043e\u043a\u0435\u0440\u0430, \u0438\u0437\u2011\u0437\u0430 \u0447\u0435\u0433\u043e \u043f\u0440\u0438 \u0441\u0435\u0442\u0435\u0432\u044b\u0445 \u0441\u0431\u043e\u044f\u0445 \u0432\u043e\u0441\u0441\u0442\u0430\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u0435 \u043f\u0440\u043e\u0438\u0441\u0445\u043e\u0434\u0438\u043b\u043e \u0441 \u0437\u0430\u0434\u0435\u0440\u0436\u043a\u0430\u043c\u0438, \u0430 \u0442\u043e\u043d\u043a\u0430\u044f \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0430 <code>consumer_timeout<\/code>, <code>broker_transport_options<\/code> \u0431\u044b\u043b\u0430 \u0441\u043b\u043e\u0436\u043d\u043e\u0439 \u0438 \u043f\u043b\u043e\u0445\u043e \u0434\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u043e\u0439.<\/p>\n<\/li>\n<li>\n<p><strong>\u0418\u0437\u0431\u044b\u0442\u043e\u0447\u043d\u043e\u0441\u0442\u044c<\/strong> \u2014 \u041a\u0430\u043a \u043c\u043e\u0436\u043d\u043e \u0437\u0430\u043c\u0435\u0442\u0438\u0442\u044c \u043c\u044b \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u043c \u043c\u0438\u043d\u0438\u043c\u0430\u043b\u044c\u043d\u044b\u0435 \u0434\u043e\u043f\u043e\u043b\u043d\u0438\u0442\u0435\u043b\u044c\u043d\u044b\u0435 \u043a\u043e\u043d\u0444\u0438\u0433\u0443\u0440\u0430\u0446\u0438\u0438 Celery.<\/p>\n<\/li>\n<li>\n<p><strong>\u041f\u0430\u0434\u0435\u043d\u0438\u0435 \u043a\u043e\u043d\u0442\u0435\u0439\u043d\u0435\u0440\u0430 \u043d\u0430 \u0431\u0438\u0442\u043e\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439<\/strong> \u2014 \u0411\u0443\u0434\u0435\u0442 \u043d\u0435 \u0441\u043e\u0432\u0441\u0435\u043c \u0441\u043f\u0440\u0430\u0432\u0435\u0434\u043b\u0438\u0432\u043e \u043e\u0442\u043d\u043e\u0441\u0438\u0442\u044c \u044d\u0442\u043e \u043f\u043e\u043b\u043d\u043e\u0441\u0442\u044c\u044e \u043a \u043c\u0438\u043d\u0443\u0441\u0430\u043c \u0441\u0430\u043c\u043e\u0433\u043e Celery, \u044d\u0442\u043e \u0431\u043e\u043b\u044c\u0448\u0435 \u043a\u0430\u043c\u0435\u043d\u044c \u0432 \u043d\u0430\u0448 \u043e\u0433\u043e\u0440\u043e\u0434. \u041d\u043e \u043e\u043f\u044b\u0442 \u0435\u0441\u0442\u044c \u043e\u043f\u044b\u0442. \u0415\u0441\u043b\u0438 \u0432\u043e\u0440\u043a\u0435\u0440 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u043b \u043d\u0435\u0432\u0430\u043b\u0438\u0434\u043d\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432 \u043f\u043b\u0430\u043d\u0435 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u044b, \u0442\u043e \u043f\u0430\u0434\u0430\u043b \u0432\u0435\u0441\u044c \u043a\u043e\u043d\u0442\u0435\u0439\u043d\u0435\u0440, \u043f\u0440\u0438 \u044d\u0442\u043e\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0438\u043b\u043e\u0441\u044c. \u0427\u0442\u043e \u043f\u0440\u0438\u0432\u043e\u0434\u0438\u043b\u043e \u043a \u043d\u0435\u043f\u043e\u043d\u0438\u043c\u0430\u043d\u0438\u044e \u201c\u043a\u0443\u0434\u0430 \u0434\u0435\u043b\u043e\u0441\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438 \u0447\u0442\u043e \u0441 \u043d\u0438\u043c \u043f\u0440\u043e\u0438\u0437\u043e\u0448\u043b\u043e?\u201d.<\/p>\n<\/li>\n<\/ul>\n<p>\u0421\u0442\u0430\u043b\u043e \u044f\u0441\u043d\u043e: Celery \u2014 \u043e\u0442\u043b\u0438\u0447\u043d\u044b\u0439 \u0432\u044b\u0431\u043e\u0440 \u0434\u043b\u044f \u0444\u043e\u043d\u043e\u0432\u044b\u0445 \u0437\u0430\u0434\u0430\u0447 \u0441 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u043e\u043c, \u043d\u043e \u0434\u043b\u044f \u043d\u0435\u043f\u0440\u0435\u0440\u044b\u0432\u043d\u043e\u0433\u043e \u043f\u043e\u0442\u043e\u043a\u043e\u0432\u043e\u0433\u043e \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0438\u043d\u0433\u0430 \u043e\u043d \u043f\u0435\u0440\u0435\u0433\u0440\u0443\u0436\u0435\u043d \u0438 \u043d\u0435\u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u043f\u0440\u043e\u0437\u0440\u0430\u0447\u0435\u043d.<\/p>\n<hr\/>\n<h3>\u0420\u0435\u0448\u0435\u043d\u0438\u0435 \u21162: aio-pika \u2014 \u0431\u043b\u0438\u0437\u043a\u043e \u043a \u0436\u0435\u043b\u0435\u0437\u0443<\/h3>\n<h4>\u0418\u0434\u0435\u044f<\/h4>\n<p>\u041f\u0435\u0440\u0435\u0439\u0442\u0438 \u043d\u0430 \u0447\u0438\u0441\u0442\u044b\u0439 AMQP, \u043e\u0442\u043a\u0430\u0437\u0430\u0432\u0448\u0438\u0441\u044c \u043e\u0442 \u043f\u043e\u0441\u0440\u0435\u0434\u043d\u0438\u043a\u0430 \u0432 \u0432\u0438\u0434\u0435 Celery. aio-pika \u2014 \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u0430\u044f \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0430 \u0434\u043b\u044f RabbitMQ, \u043f\u0440\u0435\u0434\u043e\u0441\u0442\u0430\u0432\u043b\u044f\u044e\u0449\u0430\u044f \u043f\u0440\u044f\u043c\u043e\u0439 \u0434\u043e\u0441\u0442\u0443\u043f \u043a \u043a\u0430\u043d\u0430\u043b\u0430\u043c, \u043e\u0431\u043c\u0435\u043d\u043d\u0438\u043a\u0430\u043c, \u043e\u0447\u0435\u0440\u0435\u0434\u044f\u043c. \u041a\u043e\u0434 \u0441\u0442\u0430\u043d\u043e\u0432\u0438\u0442\u0441\u044f \u043c\u0438\u043d\u0438\u043c\u0430\u043b\u044c\u043d\u043e\u0439 \u043f\u0440\u043e\u0441\u043b\u043e\u0439\u043a\u043e\u0439 \u043d\u0430\u0434 \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b\u043e\u043c: \u0441\u0430\u043c\u0438 \u0443\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u043f\u043e\u0434\u043f\u0438\u0441\u043a\u0430\u043c\u0438, \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u044f\u043c\u0438 (ack\/nack), \u043f\u0440\u0435\u0444\u0435\u0442\u0447\u0435\u043c, \u0440\u0435\u043a\u043e\u043d\u043d\u0435\u043a\u0442\u0430\u043c\u0438.<\/p>\n<h4>\u0427\u0442\u043e \u043f\u0435\u0440\u0435\u043f\u0438\u0441\u0430\u043b\u0438<\/h4>\n<p>\u041d\u0430\u043f\u0438\u0441\u0430\u043b\u0438 \u043d\u0435\u0431\u043e\u043b\u044c\u0448\u043e\u0439 \u0441\u043e\u0431\u0441\u0442\u0432\u0435\u043d\u043d\u044b\u0439 \u201c\u0444\u0440\u0435\u0439\u043c\u0432\u043e\u0440\u043a\u201d \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0438\u043d\u0433\u0430: \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u0440\u0430\u043d\u043d\u0435\u0440, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043f\u0440\u0438 \u0437\u0430\u043f\u0443\u0441\u043a\u0435 \u0441\u043e\u0437\u0434\u0430\u0451\u0442 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435, \u043e\u0442\u043a\u0440\u044b\u0432\u0430\u0435\u0442 \u043a\u0430\u043d\u0430\u043b, \u043e\u0431\u044a\u044f\u0432\u043b\u044f\u0435\u0442 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 \u0441 \u043d\u0443\u0436\u043d\u044b\u043c\u0438 \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440\u0430\u043c\u0438 durable\/exclusive, \u043f\u043e\u0434\u043f\u0438\u0441\u044b\u0432\u0430\u0435\u0442\u0441\u044f \u043d\u0430 \u043d\u0438\u0445, \u0430 \u0432 \u043a\u043e\u043b\u0431\u044d\u043a\u0435 \u0432\u044b\u0437\u044b\u0432\u0430\u0435\u0442 \u043d\u0430\u0448\u0438 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u0438. <\/p>\n<p>\u041f\u043e\u0432\u0435\u0440\u0445 \u044d\u0442\u043e\u0433\u043e \u043f\u043e\u044f\u0432\u0438\u043b\u0438\u0441\u044c:<\/p>\n<ul>\n<li>\n<p><strong>\u0420\u0443\u0447\u043d\u043e\u0439 retry<\/strong> \u2014 \u0414\u0435\u043a\u043e\u0440\u0430\u0442\u043e\u0440 \u043f\u043e\u0432\u0435\u0440\u0445 \u043a\u043e\u043b\u0431\u044d\u043a\u0430, \u0438\u043c\u0435\u044e\u0449\u0438\u0439 \u0441\u0432\u043e\u0439 \u0441\u0447\u0451\u0442\u0447\u0438\u043a \u043a\u043e\u043b-\u0432\u043e \u043f\u043e\u0432\u0442\u043e\u0440\u043e\u0432 \u043f\u0440\u0438 \u0432\u043e\u0437\u043d\u0438\u043a\u043d\u043e\u0432\u0435\u043d\u0438\u0439 \u043e\u0448\u0438\u0431\u043e\u043a.<\/p>\n<\/li>\n<li>\n<p><strong>LivenessProb<\/strong> \u2014 \u041a\u0430\u0441\u0442\u043e\u043c\u043d\u044b\u0439 \u043d\u0430 \u0443\u0440\u043e\u0432\u043d\u0435 \u044f\u0434\u0440\u0430 aio-pika \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u043b\u0435\u043d \u0447\u0443\u0442\u044c \u043d\u0438\u0436\u0435.<\/p>\n<\/li>\n<li>\n<p><strong>\u0422\u0440\u0435\u0439\u0441\u0438\u043d\u0433<\/strong> \u2014 \u0432\u0440\u0443\u0447\u043d\u0443\u044e \u043e\u0431\u043e\u0440\u0430\u0447\u0438\u0432\u0430\u0435\u043c \u0432\u044b\u0437\u043e\u0432\u044b \u0432 OpenTelemetry \u0441\u043f\u0430\u043d\u044b, \u043f\u0435\u0440\u0435\u0434\u0430\u0451\u043c trace context \u0432 \u0437\u0430\u0433\u043e\u043b\u043e\u0432\u043a\u0430\u0445 AMQP \u043f\u0440\u0438 \u0440\u0435\u0442\u0440\u0430\u044f\u0445.<\/p>\n<\/li>\n<\/ul>\n<p>\u041f\u0440\u0438\u043c\u0435\u0440 LivenessProb:<\/p>\n<pre><code class=\"python\">class CustomRobustConnection(RobustConnection):    def __init__(        self,        url: URL,        loop: asyncio.AbstractEventLoop | None = None,        **kwargs: Any,    ):        super().__init__(url=url, loop=loop, **kwargs)        # \u041a\u0430\u0441\u0442\u043e\u043c\u043d\u044b\u0439 \u043a\u043b\u0430\u0441\u0441 \u043f\u0440\u043e\u0431\u044b, \u0441\u0445\u043e\u0436 \u0441 \u0442\u0435\u043c, \u0447\u0442\u043e \u0432\u044b\u0448\u0435 \u0434\u043b\u044f Celery        self._liveness_probe = LivenessProbe()    async def connect(self, timeout: TimeoutType = None) -&gt; None:        # \u0422\u0443\u0442 \u0434\u0435\u0440\u0436\u0438\u0442\u0435\u0441\u044c \u043a\u0440\u0435\u043f\u0447\u0435. \u042f \u043a\u043e\u0433\u0434\u0430 \u0432\u043f\u0435\u0440\u0432\u044b\u0435 \u044d\u0442\u043e \u0443\u0432\u0438\u0434\u0435\u043b, \u0431\u0435\u0437 \u043b\u0438\u0442\u0440\u0430 \u043a\u043e\u0444\u0435 \u043d\u0435 \u0441\u043c\u043e\u0433 \u043f\u043e\u043d\u044f\u0442\u044c \u043a\u0430\u043a \u043e\u043d\u043e \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442        self._RobustConnection__connect_timeout = timeout        if self.is_closed:            raise RuntimeError(f\"{self!r} connection closed\")        if self.reconnecting:            raise RuntimeError(                (                    \"Connect method called but connection \"                    f\"{self!r} is reconnecting right now.\"                ),                self,            )        if not self._RobustConnection__reconnection_task:            self._RobustConnection__reconnection_task = self.loop.create_task(                self.__connection_factory(),            )        await self._RobustConnection__fail_fast_future        await self.connected.wait()    async def __connection_factory(self) -&gt; None:        logger.debug(\"Starting connection factory for %r\", self)        while not self.is_closed and not self._close_called:            logger.debug(\"Waiting for connection close event for %r\", self)            await self._RobustConnection__connection_close_event.wait()            if self.is_closed or self._close_called:                return            try:                self.transport = None                self.connected.clear()                logger.debug(\"Connection attempt for %r\", self)                await Connection.connect(self, self._RobustConnection__connect_timeout)                if not self._RobustConnection__fail_fast_future.done():                    self._RobustConnection__fail_fast_future.set_result(None)                logger.debug(\"Connection made on %r\", self)                self._liveness_probe.start()            except CONNECTION_EXCEPTIONS as e:                if not self._RobustConnection__fail_fast_future.done():                    self._RobustConnection__fail_fast_future.set_exception(e)                    return                logger.warning(                    'Connection attempt to \"%s\" failed: %s. '                    \"Reconnecting after %r seconds.\",                    self,                    e,                    self.reconnect_interval,                )                self._liveness_probe.stop()            except Exception:                logger.exception(                    \"Reconnect attempt failed %s. \" \"Retrying after %r seconds.\",                    self,                    self.reconnect_interval,                )                self._liveness_probe.stop()            await asyncio.sleep(self.reconnect_interval)<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:14px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<h4>\u0427\u0442\u043e \u0441\u0442\u0430\u043b\u043e \u043b\u0443\u0447\u0448\u0435<\/h4>\n<p>\u041f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044c \u043d\u0430\u0434 \u0436\u0438\u0437\u043d\u0435\u043d\u043d\u044b\u043c \u0446\u0438\u043a\u043b\u043e\u043c \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f, \u0442\u043e\u043d\u043a\u0430\u044f \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0430 prefetch, \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u044c \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u043b\u044e\u0431\u0443\u044e \u043b\u043e\u0433\u0438\u043a\u0443 \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u044f (\u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u043e\u0442\u043b\u043e\u0436\u0435\u043d\u043d\u044b\u0439 ack \u043f\u043e\u0441\u043b\u0435 \u0437\u0430\u0432\u0435\u0440\u0448\u0435\u043d\u0438\u044f \u0446\u0435\u043f\u043e\u0447\u043a\u0438 \u0434\u0435\u0439\u0441\u0442\u0432\u0438\u0439). \u041d\u0435\u0442 \u043b\u0438\u0448\u043d\u0438\u0445 \u043c\u0435\u0442\u0430\u0434\u0430\u043d\u043d\u044b\u0445 \u0432 \u0442\u0435\u043b\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u2014 \u0431\u0440\u043e\u043a\u0435\u0440 \u043f\u0435\u0440\u0435\u0434\u0430\u0451\u0442 \u0440\u043e\u0432\u043d\u043e \u0442\u043e, \u0447\u0442\u043e \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u043b \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440. \u0410\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0441\u0442\u044c \u043d\u0430\u0442\u0438\u0432\u043d\u0430\u044f, \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u043d\u0430 asyncio \u0431\u0435\u0437 \u043a\u043e\u0441\u0442\u044b\u043b\u0435\u0439.<\/p>\n<h4>\u041f\u0440\u043e\u0431\u043b\u0435\u043c\u044b<\/h4>\n<p>\u041a\u0430\u0436\u0434\u0430\u044f \u00ab\u043f\u043b\u044e\u0448\u043a\u0430\u00bb \u0434\u0435\u043b\u0430\u043b\u0430\u0441\u044c \u0432\u0440\u0443\u0447\u043d\u0443\u044e \u0438 \u0441\u043e \u0432\u0440\u0435\u043c\u0435\u043d\u0435\u043c \u043e\u0431\u044a\u0451\u043c \u0438\u043d\u0444\u0440\u0430\u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430 \u0440\u0430\u0437\u0440\u043e\u0441\u0441\u044f. \u0414\u0435\u0441\u044f\u0442\u043a\u0438 \u0441\u0442\u0440\u043e\u043a \u0434\u043b\u044f \u0434\u0435\u043a\u043b\u0430\u0440\u0430\u0446\u0438\u0438 \u043e\u0447\u0435\u0440\u0435\u0434\u0435\u0439, \u043b\u043e\u0433\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 reconnect\u2011\u0446\u0438\u043a\u043b\u0430, \u0441\u043e\u0433\u043b\u0430\u0441\u043e\u0432\u0430\u043d\u0438\u0435 \u0444\u043e\u0440\u043c\u0430\u0442\u0430 trace\u2011\u0437\u0430\u0433\u043e\u043b\u043e\u0432\u043a\u043e\u0432 \u043c\u0435\u0436\u0434\u0443 \u0441\u0435\u0440\u0432\u0438\u0441\u0430\u043c\u0438. Healthcheck, \u0445\u043e\u0442\u044c \u0438 \u0431\u044b\u043b \u0441\u043e\u0437\u0434\u0430\u043d \u0432\u0440\u0443\u0447\u043d\u0443\u044e, \u0442\u0440\u0435\u0431\u043e\u0432\u0430\u043b \u0430\u043a\u043a\u0443\u0440\u0430\u0442\u043d\u043e\u0441\u0442\u0438: \u043d\u0443\u0436\u043d\u043e \u0431\u044b\u043b\u043e \u043e\u0442\u0441\u043b\u0435\u0436\u0438\u0432\u0430\u0442\u044c \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u0435 \u043d\u0435 \u0442\u043e\u043b\u044c\u043a\u043e TCP-\u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f, \u043d\u043e \u0438 \u043e\u0442\u043a\u0440\u044b\u0442\u043e\u0433\u043e \u043a\u0430\u043d\u0430\u043b\u0430.<\/p>\n<hr\/>\n<h3>\u0420\u0435\u0448\u0435\u043d\u0438\u0435 \u21163: FastStream \u2014 \u0437\u043e\u043b\u043e\u0442\u0430\u044f \u0441\u0435\u0440\u0435\u0434\u0438\u043d\u0430<\/h3>\n<h4>\u041e\u0441\u043d\u043e\u0432\u043d\u0430\u044f \u0438\u0434\u0435\u044f<\/h4>\n<p>FastStream \u2014 \u043d\u0430\u0434\u0441\u0442\u0440\u043e\u0439\u043a\u0430 \u043d\u0430\u0434 aio-pika (\u0430 \u0442\u0430\u043a\u0436\u0435 \u043d\u0430\u0434 NATS, Kafka), \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0434\u0430\u0451\u0442 \u0434\u0435\u043a\u043b\u0430\u0440\u0430\u0442\u0438\u0432\u043d\u044b\u0439 \u0441\u0442\u0438\u043b\u044c \u043e\u043f\u0438\u0441\u0430\u043d\u0438\u044f consumer\u2019\u043e\u0432, lifespan\u2011\u0445\u0443\u043a\u0438, \u0432\u0441\u0442\u0440\u043e\u0435\u043d\u043d\u044b\u0435 \u043c\u0435\u0445\u0430\u043d\u0438\u0437\u043c\u044b: healthcheck-\u044d\u043d\u0434\u043f\u043e\u0438\u043d\u0442, OpenTelemetry-\u0438\u043d\u0442\u0435\u0433\u0440\u0430\u0446\u0438\u044f, \u043c\u0435\u0442\u0440\u0438\u043a\u0438 Prometheus. <\/p>\n<p>\u041f\u043e \u0441\u0443\u0442\u0438, \u044d\u0442\u043e aio-pika, \u043e\u0431\u0451\u0440\u043d\u0443\u0442\u0430\u044f \u0432 \u043b\u0443\u0447\u0448\u0438\u0435 \u043f\u0440\u0430\u043a\u0442\u0438\u043a\u0438, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043c\u044b \u0441\u0430\u043c\u0438 \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u044b\u0432\u0430\u043b\u0438 \u0440\u0443\u043a\u0430\u043c\u0438 \u0432 \u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0435\u043c \u0440\u0435\u0448\u0435\u043d\u0438\u0438. \u041c\u0435\u0445\u0430\u043d\u0438\u0437\u043c retry \u043e\u043f\u0438\u0441\u0430\u043d \u043a\u0430\u043a \u043f\u0440\u0438\u043c\u0435\u0440 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u044f middleware.<\/p>\n<h4>\u0427\u0442\u043e \u043f\u043e\u0448\u043b\u043e \u0442\u0430\u043a<\/h4>\n<ul>\n<li>\n<p><strong>Healthcheck \u0438\u0437 \u043a\u043e\u0440\u043e\u0431\u043a\u0438<\/strong> \u2014 \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u0443\u043a\u0430\u0437\u0430\u0442\u044c <code>FastStream<\/code> \u043e\u0431\u044a\u0435\u043a\u0442 \u0432 ASGI-\u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0438 (\u0447\u0435\u0440\u0435\u0437 <code>AsgiFastStream<\/code>), \u0438 \u043d\u0430 <code>\/health<\/code> \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u0442\u0441\u044f \u0441\u0442\u0430\u0442\u0443\u0441 \u0431\u0440\u043e\u043a\u0435\u0440\u0430.<\/p>\n<\/li>\n<li>\n<p><strong>Lifespan<\/strong> \u2014 \u043c\u0435\u043d\u0435\u0434\u0436\u0435\u0440 \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u0430 \u0443\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442 \u0437\u0430\u043f\u0443\u0441\u043a\u043e\u043c \u0438 \u043a\u043e\u0440\u0440\u0435\u043a\u0442\u043d\u043e\u0439 \u043e\u0441\u0442\u0430\u043d\u043e\u0432\u043a\u043e\u0439 consumer\u2019\u043e\u0432, \u043f\u043e\u0432\u0442\u043e\u0440\u043d\u044b\u043c\u0438 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f\u043c\u0438. \u041d\u0435 \u043d\u0443\u0436\u043d\u043e \u043f\u0438\u0441\u0430\u0442\u044c \u0441\u0432\u043e\u0438 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u0438 \u0441\u0438\u0433\u043d\u0430\u043b\u043e\u0432. \u042d\u0442\u043e \u043a\u0430\u0441\u0430\u043b\u043e\u0441\u044c \u043d\u0435 \u0442\u043e\u043b\u044c\u043a\u043e RMQ \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0432, \u043d\u043e \u0438 \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440 \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0432 \u043a \u0431\u0430\u0437\u0430\u043c \u0434\u0430\u043d\u043d\u044b\u0445.<\/p>\n<\/li>\n<li>\n<p><strong>\u041c\u043e\u043d\u0438\u0442\u043e\u0440\u0438\u043d\u0433 \u0438 \u0442\u0440\u0435\u0439\u0441\u0438\u043d\u0433<\/strong> \u2014 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435 OpenTelemetry \u0441\u0432\u043e\u0434\u0438\u0442\u0441\u044f \u043a \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u043c \u0441\u0442\u0440\u043e\u0447\u043a\u0430\u043c: \u0441\u043f\u0430\u043d\u044b \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0441\u043e\u0437\u0434\u0430\u044e\u0442\u0441\u044f \u0434\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0430\u043d\u043d\u043e\u0433\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, propagate context \u0447\u0435\u0440\u0435\u0437 \u0437\u0430\u0433\u043e\u043b\u043e\u0432\u043a\u0438.<\/p>\n<\/li>\n<li>\n<p><strong>\u0414\u0435\u043a\u043b\u0430\u0440\u0430\u0442\u0438\u0432\u043d\u044b\u0435 middleware<\/strong> \u2014 \u043f\u0440\u043e\u0449\u0435 \u0432\u043d\u0435\u0434\u0440\u044f\u0442\u044c \u043a\u0440\u043e\u0441\u0441\u2011\u043a\u0430\u0441\u0430\u0442\u0435\u043b\u044c\u043d\u0443\u044e \u043b\u043e\u0433\u0438\u043a\u0443 (\u043b\u043e\u0433\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435, \u0432\u0430\u043b\u0438\u0434\u0430\u0446\u0438\u044e) \u0431\u0435\u0437 \u0437\u0430\u0445\u043b\u0430\u043c\u043b\u0435\u043d\u0438\u044f \u0431\u0438\u0437\u043d\u0435\u0441-\u043a\u043e\u0434\u0430.<\/p>\n<\/li>\n<li>\n<p><strong>\u041f\u0440\u043e\u0441\u0442\u043e\u0442\u0430 \u043a\u043e\u043d\u0444\u0438\u0433\u0443\u0440\u0430\u0446\u0438\u0438<\/strong> \u2014 \u0431\u0440\u043e\u043a\u0435\u0440, \u043e\u0447\u0435\u0440\u0435\u0434\u0438, \u043e\u0431\u043c\u0435\u043d\u043d\u0438\u043a\u0438 \u043e\u043f\u0438\u0441\u044b\u0432\u0430\u044e\u0442\u0441\u044f \u0447\u0435\u0440\u0435\u0437 Python-\u0434\u0435\u043a\u043e\u0440\u0430\u0442\u043e\u0440\u044b \u0438 \u0442\u0438\u043f\u044b, \u043d\u0435\u0442 \u043d\u0443\u0436\u0434\u044b \u0432\u0440\u0443\u0447\u043d\u0443\u044e \u0443\u043f\u0440\u0430\u0432\u043b\u044f\u0442\u044c \u043a\u0430\u043d\u0430\u043b\u0430\u043c\u0438 \u0438 ack\/nack.<\/p>\n<\/li>\n<li>\n<p><strong>\u0418\u043d\u0442\u0435\u0433\u0440\u0430\u0446\u0438\u044f \u0441 Pydantic<\/strong> \u2014 \u0421\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043d\u0430 \u0443\u0440\u043e\u0432\u043d\u0435 \u043e\u043f\u0438\u0441\u0430\u043d\u0438\u0435 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u043e\u0432 \u0441\u0440\u0430\u0437\u0443 \u043f\u044b\u0442\u0430\u0435\u0442\u0441\u044f \u043e\u0442\u0432\u0430\u043b\u0438\u0434\u0438\u0440\u043e\u0432\u0430\u0442\u044c\u0441\u044f \u0432 Pydantic \u043c\u043e\u0434\u0435\u043b\u044c, \u0435\u0441\u043b\u0438 \u044d\u0442\u043e \u043d\u0443\u0436\u043d\u043e.<\/p>\n<\/li>\n<li>\n<p><strong>Dependency Injection<\/strong> \u2014 \u041a\u0430\u043a \u043c\u043e\u0436\u043d\u043e \u0443\u0432\u0438\u0434\u0435\u0442\u044c \u0432 \u043f\u0440\u0438\u043c\u0435\u0440\u0435 \u043d\u0438\u0436\u0435 <code>FastStream<\/code> \u043f\u0440\u0435\u0434\u043b\u0430\u0433\u0430\u0435\u0442 \u043d\u0430\u043c \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u044c \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435 DI \u043a\u0430\u043a \u0432 <code>FastAPI<\/code>.<\/p>\n<\/li>\n<\/ul>\n<p>\u0412\u043e\u0442 \u0432\u043e \u0447\u0442\u043e \u043f\u0440\u0435\u0432\u0440\u0430\u0442\u0438\u043b\u0430\u0441\u044c \u043a\u043e\u0434\u043e\u0432\u0430\u044f \u0431\u0430\u0437\u0430 \u043e\u0434\u043d\u043e\u0439 \u0438\u043d\u0438\u0446\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0430:<\/p>\n<pre><code class=\"python\">app = AsgiFastStream(    broker,    # health + metrics \u0438\u0437 \u043a\u043e\u0440\u043e\u0431\u043a\u0438    asgi_routes=[        (            \"\/health\",            make_system_ping_asgi(broker, timeout=5.0, include_in_schema=False),        ),        (\"\/metrics\", make_asgi_app(registry)),    ],    # \u041a\u0430\u0441\u0442\u043e\u043c\u043d\u044b\u0439 lifespan. \u041e\u0431\u044b\u0447\u043d\u043e \u0437\u0434\u0435\u0441\u044c \u0438\u0434\u0451\u0442 \u0438\u043d\u0438\u0446\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0439 \u043a \u0411\u0414    lifespan=lifespan,)<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:14px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<p>\u0411\u044b\u043b\u043e \u0431\u044b \u0435\u0449\u0451 \u043d\u0435 \u043e\u0447\u0435\u043d\u044c \u0441\u043f\u0440\u0430\u0432\u0435\u0434\u043b\u0438\u0432\u043e \u043d\u0435 \u043f\u043e\u043a\u0430\u0437\u0430\u0442\u044c, \u0447\u0442\u043e \u0438\u0437 \u0441\u0435\u0431\u044f \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u043b\u044f\u0435\u0442 broker<\/p>\n<pre><code class=\"python\">broker = RabbitBroker(    settings.RMQ_URL,    # \u041f\u0440\u0438\u043c\u0435\u0440\u044b \u043c\u0438\u0434\u0434\u043b\u0432\u0430\u0440\u044b    # RabbitPrometheusMiddleware \u0438\u0437 \u043a\u043e\u0440\u043e\u0431\u043a\u0438 \u0434\u043b\u044f \u043c\u043e\u043d\u0438\u0442\u043e\u0440\u0438\u043d\u0433\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439    # EnrichLogMiddleware \u0438 FailCatchComplexMiddleware \u043a\u0430\u0441\u0442\u043e\u043c\u043d\u044b\u0435 \u0434\u043b\u044f \u043e\u0442\u0441\u043b\u0435\u0436\u0438\u0432\u0430\u043d\u0438\u044f \u043b\u043e\u0433\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f \u0438 \u043e\u0448\u0438\u0431\u043e\u043a     middlewares=(        RabbitPrometheusMiddleware(registry=registry),        EnrichLogMiddleware,        FailCatchComplexMiddleware(            ignore_routing_keys=[                settings.RMQ_FAIL_TABLE_QUEUE,                settings.RMQ_DASHBOARD_SETTINGS_QUEUE,                settings.RMQ_TIMEOUT_QUEUE,            ],        ),    ),    logger=logger,    # \u041a\u0430\u0441\u0442\u043e\u043c\u043d\u044b\u0435 \u043f\u0430\u0440\u0441\u0435\u0440\u044b \u0438 \u0434\u0435\u043a\u043e\u0434\u0435\u0440\u044b \u0434\u043b\u044f \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0432\u0445\u043e\u0434\u044f\u0449\u0438\u0445 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439    parser=json_parser,    decoder=decoder,)broker.include_router(router)<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:14px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<p>\u0438 \u043f\u0440\u0438\u043c\u0435\u0440 \u043a\u0430\u043a \u0438\u043d\u0438\u0446\u0438\u0430\u043b\u0438\u0437\u0438\u0440\u0443\u0435\u0442\u0441\u044f \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440<\/p>\n<pre><code class=\"python\">from faststream import Dependsfrom faststream.rabbit import (    ExchangeType,    RabbitExchange,    RabbitMessage,    RabbitQueue,    RabbitRouter,)from faststream.rabbit.annotations import RabbitBroker as ContextRabbitBroker# \u0412\u043c\u0435\u0441\u0442\u043e RabbitRouter \u043c\u043e\u0436\u043d\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c broker.router = RabbitRouter()@router.subscriber(    RabbitQueue(        name=...,        durable=True,        routing_key=...,    ),    RabbitExchange(        name=...,        durable=True,    ),)async def on_service_hub_message(    message: RabbitMessage,    # \u0418\u043c\u0435\u0435\u0442\u0441\u044f \u043e\u0431\u0449\u0438\u0439 \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442 \u0432\u0441\u0435\u0439 \u0441\u0438\u0441\u0442\u0435\u043c\u044b    broker: ContextRabbitBroker,    # DI    async_session=Depends(get_db_session),) -&gt; None:<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:14px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<p>\u041f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u043e\u0432 \u043f\u0440\u043e\u0441\u0442\u043e\u0435, \u043f\u043e\u0447\u0442\u0438 \u0441\u0445\u043e\u0436\u0435\u0435 \u0441 Celery, \u043d\u043e \u0447\u0443\u0442\u044c \u0448\u0438\u0440\u0435. \u0412\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u0438 <code>FastStream<\/code> \u043d\u0430 \u044d\u0442\u043e\u043c \u043d\u0435 \u0437\u0430\u043a\u0430\u043d\u0447\u0438\u0432\u0430\u044e\u0442\u0441\u044f. \u0415\u0441\u043b\u0438 \u043a\u043e\u043f\u0430\u0442\u044c \u0435\u0449\u0451 \u0433\u043b\u0443\u0431\u0436\u0435, \u0442\u043e \u0442\u0430\u043c \u043c\u043e\u0436\u043d\u043e \u043d\u0430\u0439\u0442\u0438 \u0434\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u044e AsyncAPI \u0438 In-memory \u0442\u0435\u0441\u0442\u044b.<\/p>\n<h4>\u0427\u0442\u043e \u043f\u043e\u0448\u043b\u043e \u043d\u0435 \u0442\u0430\u043a<\/h4>\n<ul>\n<li>\n<p><strong>\u041f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c<\/strong> \u2014 \u0438\u0437-\u0437\u0430 \u0434\u043e\u043f\u043e\u043b\u043d\u0438\u0442\u0435\u043b\u044c\u043d\u044b\u0445 \u0441\u043b\u043e\u0451\u0432 \u0430\u0431\u0441\u0442\u0440\u0430\u043a\u0446\u0438\u0438 (middleware, \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0430\u044f \u043e\u0431\u0432\u044f\u0437\u043a\u0430 \u0441\u043f\u0430\u043d\u043e\u0432, \u0432\u0441\u0442\u0440\u043e\u0435\u043d\u043d\u044b\u0435 \u0440\u0435\u0442\u0440\u0430\u0438) \u043f\u0440\u043e\u043f\u0443\u0441\u043a\u043d\u0430\u044f \u0441\u043f\u043e\u0441\u043e\u0431\u043d\u043e\u0441\u0442\u044c \u043d\u0438\u0436\u0435, \u0447\u0435\u043c \u0443 \u0433\u043e\u043b\u043e\u0433\u043e aio-pika. \u042d\u0442\u043e \u0434\u043b\u044f \u043d\u0430\u0441 \u043b\u0438\u0448\u044c \u0442\u043e\u043b\u044c\u043a\u043e \u0432 \u0442\u0435\u043e\u0440\u0438\u0438, \u043f\u043e\u0441\u043a\u043e\u043b\u044c\u043a\u0443 \u043f\u043e\u0442\u043e\u043a \u043d\u0435 \u0434\u043e\u0441\u0442\u0438\u0433\u0430\u0435\u0442 \u0431\u043e\u043b\u044c\u0448\u0438\u0445 \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0439 30-40 RPS. \u0421\u043f\u0440\u0430\u0432\u0435\u0434\u043b\u0438\u0432\u043e\u0441\u0442\u0438 \u0440\u0430\u0434\u0438, \u044d\u0442\u043e \u043d\u0435 \u043e\u0442\u043d\u043e\u0441\u0438\u0442\u0441\u044f \u043a \u043c\u0438\u043d\u0443\u0441\u0430\u043c, \u043f\u043e\u0441\u043a\u043e\u043b\u044c\u043a\u0443 \u0431\u0435\u043d\u0447\u043c\u0430\u0440\u043a\u0438 \u044f \u043d\u0435 \u043f\u0440\u043e\u0432\u043e\u0434\u0438\u043b, \u0438 \u0444\u0440\u0430\u0437\u0430 \u201c\u043f\u043e\u0432\u0435\u0440\u044c \u043c\u043d\u0435 \u0431\u0440\u0430\u0442\u201d \u043c\u0435\u043d\u044f \u0443\u0431\u0435\u0434\u0438\u043b\u0430.<\/p>\n<\/li>\n<li>\n<p><strong>\u0421\u043b\u043e\u0436\u043d\u043e\u0441\u0442\u044c \u043e\u0442\u0441\u043b\u0435\u0436\u0438\u0432\u0430\u043d\u0438\u044f \u043a\u043e\u0434\u043e\u0432\u043e\u0439 \u0431\u0430\u0437\u044b<\/strong> \u2014 \u0422\u0443\u0442 \u043e\u043f\u044f\u0442\u044c \u0438\u0437-\u0437\u0430 \u0434\u043e\u043f\u043e\u043b\u043d\u0438\u0442\u0435\u043b\u044c\u043d\u044b\u0445 \u0441\u043b\u043e\u0451\u0432 \u0430\u0431\u0441\u0442\u0440\u0430\u043a\u0446\u0438\u0438 \u0438\u043d\u043e\u0433\u0434\u0430 \u0437\u0430\u0445\u043e\u0434\u0438\u0448\u044c \u0432\u043d\u0443\u0442\u0440\u044c \u043f\u043e\u0441\u043c\u043e\u0442\u0440\u0435\u0442\u044c \u0447\u0442\u043e \u0442\u0430\u043c, \u0438 \u043c\u043e\u0436\u043d\u043e \u0441 \u043b\u0451\u0433\u043a\u043e\u0441\u0442\u044c\u044e \u043f\u043e\u0442\u0435\u0440\u044f\u0442\u044c\u0441\u044f.<\/p>\n<\/li>\n<\/ul>\n<h4>\u0418\u0442\u043e\u0433\u043e\u0432\u043e\u0435 \u0441\u0440\u0430\u0432\u043d\u0435\u043d\u0438\u0435<\/h4>\n<div>\n<div class=\"table\">\n<table>\n<tbody>\n<tr>\n<th>\n<p align=\"left\">\u041a\u0440\u0438\u0442\u0435\u0440\u0438\u0439<\/p>\n<\/th>\n<th>\n<p align=\"left\">Celery<\/p>\n<\/th>\n<th>\n<p align=\"left\">aio-pika (\u0441\u0430\u043c\u043e\u043f\u0438\u0441\u043d\u044b\u0439)<\/p>\n<\/th>\n<th>\n<p align=\"left\">FastStream<\/p>\n<\/th>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">\u041f\u043e\u0434\u0445\u043e\u0434<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0414\u0438\u043d\u0430\u043c\u0438\u0447\u0435\u0441\u043a\u0438\u0435 \u0437\u0430\u0434\u0430\u0447\u0438<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u041d\u0438\u0437\u043a\u043e\u0443\u0440\u043e\u0432\u043d\u0435\u0432\u044b\u0439 AMQP<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0412\u044b\u0441\u043e\u043a\u043e\u0443\u0440\u043e\u0432\u043d\u0435\u0432\u044b\u0439 consumer<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">\u0410\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0441\u0442\u044c<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u041e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d\u043d\u0430\u044f (gevent)<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u041f\u043e\u043b\u043d\u0430\u044f (asyncio)<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u041f\u043e\u043b\u043d\u0430\u044f (asyncio)<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">Healthcheck<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0422\u0440\u0435\u0431\u0443\u0435\u0442 \u0434\u043e\u043f. \u0440\u0435\u0448\u0435\u043d\u0438\u044f<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0420\u0443\u0447\u043d\u0430\u044f \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0418\u0437 \u043a\u043e\u0440\u043e\u0431\u043a\u0438<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">Retry<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0412\u0441\u0442\u0440\u043e\u0435\u043d \u0432 \u0437\u0430\u0434\u0430\u0447\u0443<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0420\u0435\u0430\u043b\u0438\u0437\u0443\u0435\u0442\u0441\u044f \u0432\u0440\u0443\u0447\u043d\u0443\u044e<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0420\u0435\u0430\u043b\u0438\u0437\u0443\u0435\u0442\u0441\u044f \u0432\u0440\u0443\u0447\u043d\u0443\u044e (\u0435\u0441\u0442\u044c \u043f\u0440\u0438\u043c\u0435\u0440)<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">\u0422\u0440\u0435\u0439\u0441\u0438\u043d\u0433 (OTel)<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0427\u0435\u0440\u0435\u0437 \u0441\u0438\u0433\u043d\u0430\u043b\u044b Celery<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0420\u0443\u0447\u043d\u043e\u0435 \u0432\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u043d\u0438\u0435<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0418\u0437 \u043a\u043e\u0440\u043e\u0431\u043a\u0438<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">\u041a\u043e\u043d\u0442\u0440\u043e\u043b\u044c<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u041d\u0438\u0437\u043a\u0438\u0439<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u041c\u0430\u043a\u0441\u0438\u043c\u0430\u043b\u044c\u043d\u044b\u0439<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0421\u0440\u0435\u0434\u043d\u0438\u0439 (middleware)<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">\u041f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0423\u043c\u0435\u0440\u0435\u043d\u043d\u0430\u044f<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0412\u044b\u0441\u043e\u043a\u0430\u044f<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0411\u043e\u043b\u044c\u0448\u0435 \u0447\u0435\u043c \u0443 Celery, \u043d\u0438\u0436\u0435 \u0447\u0435\u043c \u0443 aio-pika<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">\u041a\u0440\u0438\u0432\u0430\u044f \u0432\u0445\u043e\u0434\u0430<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u041d\u0438\u0437\u043a\u0430\u044f<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0421\u0440\u0435\u0434\u043d\u044f\u044f (\u0442\u0440\u0435\u0431\u0443\u0435\u0442 \u0437\u043d\u0430\u043d\u0438\u0439 AMQP)<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u041d\u0438\u0437\u043a\u0430\u044f (\u0437\u043d\u0430\u043a\u043e\u043c\u043e \u043f\u043e FastAPI)<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n<hr\/>\n<h3>\u0417\u0430\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435<\/h3>\n<p>\u041f\u0440\u043e\u0439\u0434\u044f \u043f\u0443\u0442\u044c \u043e\u0442 \u043c\u043e\u043d\u043e\u043b\u0438\u0442\u043d\u043e\u0433\u043e Celery \u0447\u0435\u0440\u0435\u0437 \u0445\u0440\u0443\u043f\u043a\u0438\u0439 \u0441\u0430\u043c\u043e\u043f\u0438\u0441\u043d\u044b\u0439 \u043a\u043e\u0434 \u0434\u043e \u0441\u0431\u0430\u043b\u0430\u043d\u0441\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u043e\u0433\u043e FastStream, \u043c\u044b \u043f\u0440\u0438\u0448\u043b\u0438 \u043a \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u0443, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0437\u0430\u043a\u0440\u044b\u0432\u0430\u0435\u0442 \u0432\u0441\u0435 \u044d\u043a\u0441\u043f\u043b\u0443\u0430\u0442\u0430\u0446\u0438\u043e\u043d\u043d\u044b\u0435 \u043f\u043e\u0442\u0440\u0435\u0431\u043d\u043e\u0441\u0442\u0438: healthcheck, \u0442\u0440\u0435\u0439\u0441\u0438\u043d\u0433, \u043c\u0435\u0442\u0440\u0438\u043a\u0438 \u2014 \u0438 \u043f\u0440\u0438 \u044d\u0442\u043e\u043c \u043d\u0435 \u0442\u0440\u0435\u0431\u0443\u0435\u0442 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0442\u044c \u0441\u043e\u0442\u043d\u0438 \u0441\u0442\u0440\u043e\u043a \u0438\u043d\u0444\u0440\u0430\u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430. <\/p>\n<p>\u0414\u0430, \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e \u044f \u0432\u044b\u0441\u0442\u0443\u043f\u0430\u044e \u0432 \u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u0430\u0434\u0432\u043e\u043a\u0430\u0442\u0430 \u044d\u0442\u043e\u0433\u043e \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u0430, \u043d\u043e \u0447\u0442\u043e \u043c\u043e\u0433\u0443 \u043f\u043e\u0434\u0435\u043b\u0430\u0442\u044c, \u043a\u043e\u0433\u0434\u0430 \u043e\u043d \u0442\u0430\u043a \u043f\u043e\u043d\u0440\u0430\u0432\u0438\u043b\u0441\u044f? \u044d\u0442\u043e \u0432\u044b \u0435\u0449\u0451 \u043d\u0435 \u0443\u0432\u0438\u0434\u0435\u043b\u0438 \u043a\u0430\u043a \u0441\u0442\u0430\u0440\u0430\u044e\u0441\u044c \u043f\u0435\u0440\u0435\u043f\u0438\u0441\u0430\u0442\u044c \u0432\u0441\u0451 \u043d\u0430 Rust. <\/p>\n<p>\u041e\u0442\u043e\u0439\u0434\u044f \u043e\u0442 \u0436\u0430\u0440\u0433\u043e\u043d\u0430 \u0438 \u0448\u0443\u0442\u043e\u043a \u043f\u043e\u0432\u0442\u043e\u0440\u044e \u043f\u0435\u0440\u0432\u0443\u044e \u0441\u0432\u043e\u044e \u043c\u044b\u0441\u043b\u044c: \u0423 \u043a\u0430\u0436\u0434\u043e\u0439 \u0437\u0430\u0434\u0430\u0447\u0438 \u0441\u0432\u043e\u0439 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442. \u041c\u043e\u0439 \u2014 \u044d\u0442\u043e FastStream.<\/p>\n<\/div>\n<p>\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\/1030082\/\">https:\/\/habr.com\/ru\/articles\/1030082\/<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"<p>\u041d\u0430\u0448 \u043f\u0443\u0442\u044c \u0430\u043a\u0442\u0438\u0432\u043d\u043e\u0439 \u0440\u0430\u0431\u043e\u0442\u044b \u0441 \u043e\u0447\u0435\u0440\u0435\u0434\u044f\u043c\u0438 RabbitMQ \u043d\u0430\u0447\u0430\u043b\u0441\u044f \u0441 \u043a\u043b\u0430\u0441\u0441\u0438\u0447\u0435\u0441\u043a\u043e\u0433\u043e Celery. \u041e\u0441\u043e\u0437\u043d\u0430\u0432 \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e\u0441\u0442\u044c \u043d\u0438\u0437\u043a\u043e\u0443\u0440\u043e\u0432\u043d\u0435\u0432\u043e\u0433\u043e \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044f \u0441\u0438\u0441\u0442\u0435\u043c\u044b, \u043f\u0440\u0438\u043d\u044f\u043b\u0438\u0441\u044c \u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u0441 aio-pika. \u041d\u043e \u0438 \u044d\u0442\u043e\u0442 \u0443\u0440\u043e\u0432\u0435\u043d\u044c \u0441\u043b\u0438\u0448\u043a\u043e\u043c \u043c\u0435\u0441\u0442\u0430\u043c\u0438 \u0441\u043b\u043e\u0436\u043d\u044b\u0439 (\u0434\u0430\u043b\u0435\u0435 \u0440\u0430\u0441\u0441\u043a\u0430\u0436\u0443 \u043f\u043e\u0447\u0435\u043c\u0443), \u0438 \u043d\u0430\u0448\u043b\u0438 \u043e\u0442\u043b\u0438\u0447\u043d\u043e\u0435 \u0440\u0435\u0448\u0435\u043d\u0438\u0435, \u043d\u0430 \u0442\u0435\u043a\u0443\u0449\u0438\u0439 \u043c\u043e\u043c\u0435\u043d\u0442, \u0432 \u043b\u0438\u0446\u0435 FastStream. \u0421\u0440\u0430\u0437\u0443 \u043e\u0441\u0442\u0430\u0432\u043b\u044e \u0442\u0430\u043a\u0443\u044e \u043f\u043e\u043c\u0435\u0442\u043a\u0443, \u0447\u0442\u043e \u043a\u0430\u0436\u0434\u044b\u0439 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442 \u043f\u043e\u0434\u0445\u043e\u0434\u0438\u0442 \u0434\u043b\u044f \u0440\u0435\u0448\u0435\u043d\u0438\u044f \u0441\u0432\u043e\u0435\u0439 \u0437\u0430\u0434\u0430\u0447\u0438. \u041c\u044b \u0431\u043e\u043b\u044c\u0448\u0435 \u0445\u043e\u0442\u0435\u043b\u0438 \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0430\u043a\u0446\u0435\u043d\u0442 \u043d\u0430 \u0443\u0434\u043e\u0431\u0441\u0442\u0432\u043e \u0438 \u0441\u043a\u043e\u0440\u043e\u0441\u0442\u044c \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u043e\u0442\u043d\u043e\u0441\u0438\u0442\u0435\u043b\u044c\u043d\u043e \u0437\u0430\u0442\u0440\u0430\u0447\u0438\u0432\u0430\u0435\u043c\u043e\u0433\u043e \u0432\u0440\u0435\u043c\u0435\u043d\u0438 \u043d\u0430 \u043c\u0438\u0433\u0440\u0430\u0446\u0438\u0438 \u0440\u0435\u0448\u0435\u043d\u0438\u0439. N.B.: \u041a\u043e\u0434 \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e \u043f\u043e\u043a\u0430\u0436\u0435\u0442\u0441\u044f \u043d\u0435\u043e\u043f\u0442\u0438\u043c\u0430\u043b\u044c\u043d\u044b\u043c \u0438\u043b\u0438 \u0441\u0442\u0430\u0440\u044b\u043c. \u042d\u0442\u043e \u0432\u0441\u0451 \u043d\u0430\u0448 \u0434\u043e\u0440\u043e\u0433\u043e\u0439 \u041b\u0435\u0433\u0430\u0441\u0438.\u041f\u043e\u0441\u0442\u0430\u043d\u043e\u0432\u043a\u0430 \u0437\u0430\u0434\u0430\u0447\u0438\u041d\u0430\u0448\u0430 \u0441\u0438\u0441\u0442\u0435\u043c\u0430 \u043f\u043e\u0441\u0442\u0440\u043e\u0435\u043d\u0430 \u043d\u0430 \u043e\u0441\u043d\u043e\u0432\u0435 \u043c\u0438\u043a\u0440\u043e\u0441\u0435\u0440\u0432\u0438\u0441\u043e\u0432, \u0440\u0430\u0431\u043e\u0442\u0430\u044e\u0449\u0438\u0445 \u0441 RabbitMQ. \u0412\u043d\u0443\u0442\u0440\u0438 &#8212; \u043e\u0431\u044b\u0447\u043d\u044b\u0439 \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u043a\u043e\u0434 \u0434\u043b\u044f \u043f\u043e\u0445\u043e\u0434\u0430 \u043d\u0430 \u0432\u043d\u0435\u0448\u043d\u0438\u0435 API \u0438 \u0432 \u0411\u0414. \u0422\u0440\u0435\u0431\u043e\u0432\u0430\u043d\u0438\u044f: \u041d\u0430\u0434\u0435\u0436\u043d\u044b\u0439 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0438\u043d\u0433 &#8212; \u044d\u0442\u043e \u0434\u043b\u044f \u043d\u0430\u0441 \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u043e, \u0447\u0442\u043e\u0431\u044b \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0448\u043b\u043e \u043f\u043e \u0432\u0441\u0435\u043c\u0443 \u0444\u043b\u043e\u0443 \u0438 \u043d\u0438\u0433\u0434\u0435 \u043d\u0435 \u043e\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u043b\u043e\u0441\u044c \u0431\u0435\u0437 \u043f\u0440\u0438\u0447\u0438\u043d. \u0415\u0441\u043b\u0438 \u043e\u0448\u0438\u0431\u043a\u0430 \u043f\u0430\u0434\u0430\u0435\u0442, \u0442\u043e \u044d\u0442\u043e \u0434\u043e\u043b\u0436\u043d\u043e \u043e\u0442\u0440\u0430\u0436\u0430\u0442\u044c\u0441\u044f \u0432 3 \u043c\u0435\u0441\u0442\u0430\u0445: \u0411\u0414, \u043b\u043e\u0433\u0438 \u0438 \u043c\u0435\u0442\u0440\u0438\u043a\u0438.\u0420\u0435\u0442\u0440\u0430\u0438 \u043f\u0440\u0438 \u043e\u0448\u0438\u0431\u043a\u0430\u0445 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438. \u0422\u0440\u0435\u0439\u0441\u0438\u043d\u0433 &#8212; \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u043a\u0430 OpenTelemetry. \u041c\u043e\u043d\u0438\u0442\u043e\u0440\u0438\u043d\u0433 \u0441\u0435\u0440\u0432\u0438\u0441\u0430 \u0447\u0435\u0440\u0435\u0437 healthcheck\u2019\u0438. Prometheus \u043c\u0435\u0442\u0440\u0438\u043a\u0438.\u0420\u0435\u0448\u0435\u043d\u0438\u0435 \u21161: Celery \u043a\u0430\u043a \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u041f\u043e\u0447\u0435\u043c\u0443 CeleryCelery \u2014 \u043a\u043b\u0430\u0441\u0441\u0438\u0447\u0435\u0441\u043a\u0438\u0439 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442 \u0434\u043b\u044f \u0444\u043e\u043d\u043e\u0432\u044b\u0445 \u0437\u0430\u0434\u0430\u0447, \u0437\u043d\u0430\u043a\u043e\u043c\u044b\u0439 \u0431\u043e\u043b\u044c\u0448\u0438\u043d\u0441\u0442\u0432\u0443 Python-\u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u043e\u0432. \u0418\u0437 \u043a\u043e\u0440\u043e\u0431\u043a\u0438: \u0434\u0435\u043a\u043b\u0430\u0440\u0430\u0442\u0438\u0432\u043d\u043e\u0435 \u043e\u043f\u0438\u0441\u0430\u043d\u0438\u0435 \u0437\u0430\u0434\u0430\u0447, \u0440\u0435\u0442\u0440\u0430\u0438 \u0441 \u044d\u043a\u0441\u043f\u043e\u043d\u0435\u043d\u0446\u0438\u0430\u043b\u044c\u043d\u043e\u0439 \u0437\u0430\u0434\u0435\u0440\u0436\u043a\u043e\u0439, \u0445\u0440\u0430\u043d\u0435\u043d\u0438\u0435 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u043e\u0432, \u043c\u043e\u043d\u0438\u0442\u043e\u0440\u0438\u043d\u0433 \u0447\u0435\u0440\u0435\u0437 Flower, \u0438\u043d\u0442\u0435\u0433\u0440\u0430\u0446\u0438\u0438 \u0441 \u0444\u0440\u0435\u0439\u043c\u0432\u043e\u0440\u043a\u0430\u043c\u0438. \u041b\u043e\u0433\u0438\u043a\u0430 \u043f\u0440\u043e\u0441\u0442\u0430: \u043f\u0438\u0448\u0435\u0448\u044c @app.task, \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u0448\u044c \u0432\u043e\u0440\u043a\u0435\u0440 \u2014 \u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0438\u0437 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 \u043d\u0430\u0447\u0438\u043d\u0430\u044e\u0442 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0442\u044c\u0441\u044f.\u041a\u0430\u043a \u043c\u044b \u0435\u0433\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043b\u0438\u041c\u044b \u043d\u0435 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u043b\u0438 \u0437\u0430\u0434\u0430\u0447\u0438 \u0438\u0437 \u043a\u043e\u0434\u0430 \u0432 \u0434\u0443\u0445\u0435 my_task.delay(), \u0430 \u043d\u0430\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u043b\u0438 Celery \u043d\u0430 \u043f\u0440\u043e\u0441\u043b\u0443\u0448\u0438\u0432\u0430\u043d\u0438\u0435 \u0432\u043d\u0435\u0448\u043d\u0435\u0439 \u043e\u0447\u0435\u0440\u0435\u0434\u0438, \u043a\u0443\u0434\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043f\u043e\u043f\u0430\u0434\u0430\u043b\u0438 \u043e\u0442 \u0434\u0440\u0443\u0433\u0438\u0445 \u0441\u0438\u0441\u0442\u0435\u043c. \u041f\u043e \u0441\u0443\u0442\u0438, Celery \u0432\u044b\u0441\u0442\u0443\u043f\u0430\u043b \u043a\u0430\u043a consumer: \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0430\u043b\u0441\u044f \u043a \u0431\u0440\u043e\u043a\u0435\u0440\u0443, \u0437\u0430\u0431\u0438\u0440\u0430\u043b \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u0434\u0435\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043b \u0438 \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u043b \u0432 \u043d\u0430\u0448\u0438 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u0438. \u041d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438 \u0432\u0440\u043e\u0434\u0435 max_retries, default_retry_delay, countdown \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u043b\u0438 \u0433\u0438\u0431\u043a\u043e \u0443\u043f\u0440\u0430\u0432\u043b\u044f\u0442\u044c \u043f\u043e\u0432\u0435\u0434\u0435\u043d\u0438\u0435\u043c \u043f\u0440\u0438 \u0441\u0431\u043e\u044f\u0445. \u0412\u0430\u0436\u043d\u043e \u0435\u0449\u0451 \u043f\u043e\u0434\u0441\u0432\u0435\u0442\u0438\u0442\u044c, \u0447\u0442\u043e \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442 \u0432\u0441\u0435\u0433\u0434\u0430 \u0438\u0433\u043d\u043e\u0440\u0438\u0440\u0443\u0435\u0442\u0441\u044f \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440\u0430 ignore_result=True \u043f\u043e\u0441\u043a\u043e\u043b\u044c\u043a\u0443 \u0432\u0441\u0435 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u044b \u0437\u0430\u043f\u0438\u0441\u044b\u0432\u0430\u044e\u0442\u0441\u044f \u0432 \u0411\u0414.\u041f\u0440\u0438\u043c\u0435\u0440 \u0438\u043d\u0438\u0446\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u0432\u043e\u0440\u043a\u0435\u0440\u0430:def create_app(    name,    broker,    include,    backend=None,    task_queues=None,    liveness_probe=1,    update_period=60,    watcher_config={},):    # \u0421\u043e\u0437\u0434\u0430\u043d\u0438\u0435 \u0441\u0430\u043c\u043e \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435 + \u043d\u0430\u043b\u043e\u0436\u0435\u043d\u0438\u0435 \u0434\u043e\u043f\u043e\u043b\u043d\u0438\u0442\u0435\u043b\u044c\u043d\u044b\u0445 \u043a\u043e\u043d\u0444\u0438\u0433\u0443\u0440\u0430\u0446\u0438\u0438    app = Celery(name, broker=broker, include=include, backend=backend)    app.conf.update(        result_expires=120,    )    add_without_heartbeat_argument = Option(        (&#171;&#8212;without-heartbeat&#187;,),        default=True,    )    app.user_options[&#171;worker&#187;].add(add_without_heartbeat_argument)    if task_queues is not None:        app.conf.task_queues = task_queues    if liveness_probe:        add_update_period_argument = Option(            (&#171;&#8212;update-period&#187;,),            default=update_period,        )        HEARTBEAT_FILE.touch()        app.user_options[&#171;worker&#187;].add(add_update_period_argument)        # \u0414\u043e\u0431\u0430\u0432\u043b\u0435\u043d\u0438\u0435 \u043a\u0430\u0441\u0442\u043e\u043c\u043d\u043e\u0439 livenessProbe \u0434\u043b\u044f K8s        app.steps[&#171;worker&#187;].add(LivenessProbe)        # \u0438\u043d\u0438\u0446\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f \u0442\u0440\u0435\u0439\u0441\u0438\u043d\u0433\u0430    with_tracing = watcher_config.get(&#171;with_tracing&#187;)    if with_tracing:        tracing_exporters = watcher_config.get(&#171;tracing_exporters&#187;, ())        signals.worker_process_init.connect(            init_celery_tracing(app_name=name, tracing_exporters=tracing_exporters),            weak=False,        )    return app\u0421 \u0447\u0435\u043c \u0441\u0442\u043e\u043b\u043a\u043d\u0443\u043b\u0438\u0441\u044cCelery \u043f\u0440\u043e\u0435\u043a\u0442\u0438\u0440\u043e\u0432\u0430\u043b\u0441\u044f \u043a\u0430\u043a \u0441\u0438\u0441\u0442\u0435\u043c\u0430 \u043f\u0435\u0440\u0435\u0434\u0430\u0447\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u043c\u0435\u0436\u0434\u0443 \u0441\u0438\u0441\u0442\u0435\u043c\u0430\u043c\u0438. \u0418\u0437-\u0437\u0430 \u0447\u0435\u0433\u043e \u0441\u0442\u043e\u043b\u043a\u043d\u0443\u043b\u0438\u0441\u044c \u0441\u043e \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0438\u043c\u0438 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0430\u043c\u0438:\u041f\u043e\u0442\u0440\u0435\u0431\u043b\u0435\u043d\u0438\u0435 \u043f\u0430\u043c\u044f\u0442\u0438 \u2014 \u0438\u0437-\u0437\u0430 \u043e\u0431\u043e\u0440\u0430\u0447\u0438\u0432\u0430\u043d\u0438\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0432 \u043c\u0435\u0442\u0430\u0434\u0430\u043d\u043d\u044b\u0435 \u0438 \u0445\u0440\u0430\u043d\u0435\u043d\u0438\u044f \u0432\u043d\u0443\u0442\u0440\u0435\u043d\u043d\u0438\u0445 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440 Celery \u0440\u0430\u0441\u0445\u043e\u0434 \u043e\u043f\u0435\u0440\u0430\u0442\u0438\u0432\u043d\u043e\u0439 \u043f\u0430\u043c\u044f\u0442\u0438 \u0431\u044b\u0441\u0442\u0440\u043e \u0440\u043e\u0441 \u043f\u0440\u043e\u043f\u043e\u0440\u0446\u0438\u043e\u043d\u0430\u043b\u044c\u043d\u043e \u043f\u043e\u0442\u043e\u043a\u0443 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439. \u041f\u0440\u0438 \u0432\u044b\u0441\u043e\u043a\u043e\u043c \u0442\u0435\u043c\u043f\u0435 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0432\u043e\u0440\u043a\u0435\u0440 \u043d\u0430\u0447\u0438\u043d\u0430\u043b \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u0437\u043d\u0430\u0447\u0438\u0442\u0435\u043b\u044c\u043d\u043e \u0431\u043e\u043b\u044c\u0448\u0435 \u041e\u0417\u0423, \u0447\u0435\u043c \u0442\u0440\u0435\u0431\u043e\u0432\u0430\u043b\u043e\u0441\u044c \u0441\u0430\u043c\u043e\u0439 \u0431\u0438\u0437\u043d\u0435\u0441-\u043b\u043e\u0433\u0438\u043a\u0435, \u0447\u0442\u043e \u0432\u044b\u043d\u0443\u0436\u0434\u0430\u043b\u043e \u0432\u044b\u0434\u0435\u043b\u044f\u0442\u044c \u0438\u0437\u0431\u044b\u0442\u043e\u0447\u043d\u044b\u0435 \u0440\u0435\u0441\u0443\u0440\u0441\u044b.\u0423\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u0438\u0435 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f\u043c\u0438 \u0438 heartbeat \u2014 Celery \u0441\u043a\u0440\u044b\u0432\u0430\u0435\u0442 \u043c\u043d\u043e\u0433\u0438\u0435 \u0434\u0435\u0442\u0430\u043b\u0438 \u0431\u0440\u043e\u043a\u0435\u0440\u0430, \u0438\u0437\u2011\u0437\u0430 \u0447\u0435\u0433\u043e \u043f\u0440\u0438 \u0441\u0435\u0442\u0435\u0432\u044b\u0445 \u0441\u0431\u043e\u044f\u0445 \u0432\u043e\u0441\u0441\u0442\u0430\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u0435 \u043f\u0440\u043e\u0438\u0441\u0445\u043e\u0434\u0438\u043b\u043e \u0441 \u0437\u0430\u0434\u0435\u0440\u0436\u043a\u0430\u043c\u0438, \u0430 \u0442\u043e\u043d\u043a\u0430\u044f \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0430 consumer_timeout, broker_transport_options \u0431\u044b\u043b\u0430 \u0441\u043b\u043e\u0436\u043d\u043e\u0439 \u0438 \u043f\u043b\u043e\u0445\u043e \u0434\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u043e\u0439.\u0418\u0437\u0431\u044b\u0442\u043e\u0447\u043d\u043e\u0441\u0442\u044c \u2014 \u041a\u0430\u043a \u043c\u043e\u0436\u043d\u043e \u0437\u0430\u043c\u0435\u0442\u0438\u0442\u044c \u043c\u044b \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u043c \u043c\u0438\u043d\u0438\u043c\u0430\u043b\u044c\u043d\u044b\u0435 \u0434\u043e\u043f\u043e\u043b\u043d\u0438\u0442\u0435\u043b\u044c\u043d\u044b\u0435 \u043a\u043e\u043d\u0444\u0438\u0433\u0443\u0440\u0430\u0446\u0438\u0438 Celery.\u041f\u0430\u0434\u0435\u043d\u0438\u0435 \u043a\u043e\u043d\u0442\u0435\u0439\u043d\u0435\u0440\u0430 \u043d\u0430 \u0431\u0438\u0442\u043e\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u2014 \u0411\u0443\u0434\u0435\u0442 \u043d\u0435 \u0441\u043e\u0432\u0441\u0435\u043c \u0441\u043f\u0440\u0430\u0432\u0435\u0434\u043b\u0438\u0432\u043e \u043e\u0442\u043d\u043e\u0441\u0438\u0442\u044c \u044d\u0442\u043e \u043f\u043e\u043b\u043d\u043e\u0441\u0442\u044c\u044e \u043a \u043c\u0438\u043d\u0443\u0441\u0430\u043c \u0441\u0430\u043c\u043e\u0433\u043e Celery, \u044d\u0442\u043e \u0431\u043e\u043b\u044c\u0448\u0435 \u043a\u0430\u043c\u0435\u043d\u044c \u0432 \u043d\u0430\u0448 \u043e\u0433\u043e\u0440\u043e\u0434. \u041d\u043e \u043e\u043f\u044b\u0442 \u0435\u0441\u0442\u044c \u043e\u043f\u044b\u0442. \u0415\u0441\u043b\u0438 \u0432\u043e\u0440\u043a\u0435\u0440 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u043b \u043d\u0435\u0432\u0430\u043b\u0438\u0434\u043d\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432 \u043f\u043b\u0430\u043d\u0435 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u044b, \u0442\u043e \u043f\u0430\u0434\u0430\u043b \u0432\u0435\u0441\u044c \u043a\u043e\u043d\u0442\u0435\u0439\u043d\u0435\u0440, \u043f\u0440\u0438 \u044d\u0442\u043e\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0438\u043b\u043e\u0441\u044c. \u0427\u0442\u043e \u043f\u0440\u0438\u0432\u043e\u0434\u0438\u043b\u043e \u043a \u043d\u0435\u043f\u043e\u043d\u0438\u043c\u0430\u043d\u0438\u044e \u201c\u043a\u0443\u0434\u0430 \u0434\u0435\u043b\u043e\u0441\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438 \u0447\u0442\u043e \u0441 \u043d\u0438\u043c \u043f\u0440\u043e\u0438\u0437\u043e\u0448\u043b\u043e?\u201d.\u0421\u0442\u0430\u043b\u043e \u044f\u0441\u043d\u043e: Celery \u2014 \u043e\u0442\u043b\u0438\u0447\u043d\u044b\u0439 \u0432\u044b\u0431\u043e\u0440 \u0434\u043b\u044f \u0444\u043e\u043d\u043e\u0432\u044b\u0445 \u0437\u0430\u0434\u0430\u0447 \u0441 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u043e\u043c, \u043d\u043e \u0434\u043b\u044f \u043d\u0435\u043f\u0440\u0435\u0440\u044b\u0432\u043d\u043e\u0433\u043e \u043f\u043e\u0442\u043e\u043a\u043e\u0432\u043e\u0433\u043e \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0438\u043d\u0433\u0430 \u043e\u043d \u043f\u0435\u0440\u0435\u0433\u0440\u0443\u0436\u0435\u043d \u0438 \u043d\u0435\u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u043f\u0440\u043e\u0437\u0440\u0430\u0447\u0435\u043d.\u0420\u0435\u0448\u0435\u043d\u0438\u0435 \u21162: aio-pika \u2014 \u0431\u043b\u0438\u0437\u043a\u043e \u043a \u0436\u0435\u043b\u0435\u0437\u0443\u0418\u0434\u0435\u044f\u041f\u0435\u0440\u0435\u0439\u0442\u0438 \u043d\u0430 \u0447\u0438\u0441\u0442\u044b\u0439 AMQP, \u043e\u0442\u043a\u0430\u0437\u0430\u0432\u0448\u0438\u0441\u044c \u043e\u0442 \u043f\u043e\u0441\u0440\u0435\u0434\u043d\u0438\u043a\u0430 \u0432 \u0432\u0438\u0434\u0435 Celery. aio-pika \u2014 \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u0430\u044f \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0430 \u0434\u043b\u044f RabbitMQ, \u043f\u0440\u0435\u0434\u043e\u0441\u0442\u0430\u0432\u043b\u044f\u044e\u0449\u0430\u044f \u043f\u0440\u044f\u043c\u043e\u0439 \u0434\u043e\u0441\u0442\u0443\u043f \u043a \u043a\u0430\u043d\u0430\u043b\u0430\u043c, \u043e\u0431\u043c\u0435\u043d\u043d\u0438\u043a\u0430\u043c, \u043e\u0447\u0435\u0440\u0435\u0434\u044f\u043c. \u041a\u043e\u0434 \u0441\u0442\u0430\u043d\u043e\u0432\u0438\u0442\u0441\u044f \u043c\u0438\u043d\u0438\u043c\u0430\u043b\u044c\u043d\u043e\u0439 \u043f\u0440\u043e\u0441\u043b\u043e\u0439\u043a\u043e\u0439 \u043d\u0430\u0434 \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b\u043e\u043c: \u0441\u0430\u043c\u0438 \u0443\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u043f\u043e\u0434\u043f\u0438\u0441\u043a\u0430\u043c\u0438, \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u044f\u043c\u0438 (ack\/nack), \u043f\u0440\u0435\u0444\u0435\u0442\u0447\u0435\u043c, \u0440\u0435\u043a\u043e\u043d\u043d\u0435\u043a\u0442\u0430\u043c\u0438.\u0427\u0442\u043e \u043f\u0435\u0440\u0435\u043f\u0438\u0441\u0430\u043b\u0438\u041d\u0430\u043f\u0438\u0441\u0430\u043b\u0438 \u043d\u0435\u0431\u043e\u043b\u044c\u0448\u043e\u0439 \u0441\u043e\u0431\u0441\u0442\u0432\u0435\u043d\u043d\u044b\u0439 \u201c\u0444\u0440\u0435\u0439\u043c\u0432\u043e\u0440\u043a\u201d \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0438\u043d\u0433\u0430: \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u0440\u0430\u043d\u043d\u0435\u0440, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043f\u0440\u0438 \u0437\u0430\u043f\u0443\u0441\u043a\u0435 \u0441\u043e\u0437\u0434\u0430\u0451\u0442 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435, \u043e\u0442\u043a\u0440\u044b\u0432\u0430\u0435\u0442 \u043a\u0430\u043d\u0430\u043b, \u043e\u0431\u044a\u044f\u0432\u043b\u044f\u0435\u0442 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 \u0441 \u043d\u0443\u0436\u043d\u044b\u043c\u0438 \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440\u0430\u043c\u0438 durable\/exclusive, \u043f\u043e\u0434\u043f\u0438\u0441\u044b\u0432\u0430\u0435\u0442\u0441\u044f \u043d\u0430 \u043d\u0438\u0445, \u0430 \u0432 \u043a\u043e\u043b\u0431\u044d\u043a\u0435 \u0432\u044b\u0437\u044b\u0432\u0430\u0435\u0442 \u043d\u0430\u0448\u0438 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u0438. \u041f\u043e\u0432\u0435\u0440\u0445 \u044d\u0442\u043e\u0433\u043e \u043f\u043e\u044f\u0432\u0438\u043b\u0438\u0441\u044c:\u0420\u0443\u0447\u043d\u043e\u0439 retry \u2014 \u0414\u0435\u043a\u043e\u0440\u0430\u0442\u043e\u0440 \u043f\u043e\u0432\u0435\u0440\u0445 \u043a\u043e\u043b\u0431\u044d\u043a\u0430, \u0438\u043c\u0435\u044e\u0449\u0438\u0439 \u0441\u0432\u043e\u0439 \u0441\u0447\u0451\u0442\u0447\u0438\u043a \u043a\u043e\u043b-\u0432\u043e \u043f\u043e\u0432\u0442\u043e\u0440\u043e\u0432 \u043f\u0440\u0438 \u0432\u043e\u0437\u043d\u0438\u043a\u043d\u043e\u0432\u0435\u043d\u0438\u0439 \u043e\u0448\u0438\u0431\u043e\u043a.LivenessProb \u2014 \u041a\u0430\u0441\u0442\u043e\u043c\u043d\u044b\u0439 \u043d\u0430 \u0443\u0440\u043e\u0432\u043d\u0435 \u044f\u0434\u0440\u0430 aio-pika \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u043b\u0435\u043d \u0447\u0443\u0442\u044c \u043d\u0438\u0436\u0435.\u0422\u0440\u0435\u0439\u0441\u0438\u043d\u0433 \u2014 \u0432\u0440\u0443\u0447\u043d\u0443\u044e \u043e\u0431\u043e\u0440\u0430\u0447\u0438\u0432\u0430\u0435\u043c \u0432\u044b\u0437\u043e\u0432\u044b \u0432 OpenTelemetry \u0441\u043f\u0430\u043d\u044b, \u043f\u0435\u0440\u0435\u0434\u0430\u0451\u043c trace context \u0432 \u0437\u0430\u0433\u043e\u043b\u043e\u0432\u043a\u0430\u0445 AMQP \u043f\u0440\u0438 \u0440\u0435\u0442\u0440\u0430\u044f\u0445.\u041f\u0440\u0438\u043c\u0435\u0440 LivenessProb:class CustomRobustConnection(RobustConnection):    def __init__(        self,        url: URL,        loop: asyncio.AbstractEventLoop | None = None,        **kwargs: Any,    ):        super().__init__(url=url, loop=loop, **kwargs)        # \u041a\u0430\u0441\u0442\u043e\u043c\u043d\u044b\u0439 \u043a\u043b\u0430\u0441\u0441 \u043f\u0440\u043e\u0431\u044b, \u0441\u0445\u043e\u0436 \u0441 \u0442\u0435\u043c, \u0447\u0442\u043e \u0432\u044b\u0448\u0435 \u0434\u043b\u044f Celery        self._liveness_probe = LivenessProbe()    async def connect(self, timeout: TimeoutType = None) -&gt; None:        # \u0422\u0443\u0442 \u0434\u0435\u0440\u0436\u0438\u0442\u0435\u0441\u044c \u043a\u0440\u0435\u043f\u0447\u0435. \u042f \u043a\u043e\u0433\u0434\u0430 \u0432\u043f\u0435\u0440\u0432\u044b\u0435 \u044d\u0442\u043e \u0443\u0432\u0438\u0434\u0435\u043b, \u0431\u0435\u0437 \u043b\u0438\u0442\u0440\u0430 \u043a\u043e\u0444\u0435 \u043d\u0435 \u0441\u043c\u043e\u0433 \u043f\u043e\u043d\u044f\u0442\u044c \u043a\u0430\u043a \u043e\u043d\u043e \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442        self._RobustConnection__connect_timeout = timeout        if self.is_closed:            raise RuntimeError(f&#187;{self!r} connection closed&#187;)        if self.reconnecting:            raise RuntimeError(                (                    &#171;Connect method called but connection &#187;                    f&#187;{self!r} is reconnecting right now.&#187;                ),                self,            )        if not self._RobustConnection__reconnection_task:            self._RobustConnection__reconnection_task = self.loop.create_task(                self.__connection_factory(),            )        await self._RobustConnection__fail_fast_future        await self.connected.wait()    async def __connection_factory(self) -&gt; None:        logger.debug(&#171;Starting connection factory for %r&#187;, self)        while not self.is_closed and not self._close_called:            logger.debug(&#171;Waiting for connection close event for %r&#187;, self)            await self._RobustConnection__connection_close_event.wait()            if self.is_closed or self._close_called:                return            try:                self.transport = None                self.connected.clear()                logger.debug(&#171;Connection attempt for %r&#187;, self)                await Connection.connect(self, self._RobustConnection__connect_timeout)                if not self._RobustConnection__fail_fast_future.done():                    self._RobustConnection__fail_fast_future.set_result(None)                logger.debug(&#171;Connection made on %r&#187;, self)                self._liveness_probe.start()            except CONNECTION_EXCEPTIONS as e:                if not self._RobustConnection__fail_fast_future.done():                    self._RobustConnection__fail_fast_future.set_exception(e)                    return                logger.warning(                    &#8216;Connection attempt to &#171;%s&#187; failed: %s. &#8216;                    &#171;Reconnecting after %r seconds.&#187;,                    self,                    e,                    self.reconnect_interval,                )                self._liveness_probe.stop()            except Exception:                logger.exception(                    &#171;Reconnect attempt failed %s. &#187; &#171;Retrying after %r seconds.&#187;,                    self,                    self.reconnect_interval,                )                self._liveness_probe.stop()            await asyncio.sleep(self.reconnect_interval)\u0427\u0442\u043e \u0441\u0442\u0430\u043b\u043e \u043b\u0443\u0447\u0448\u0435\u041f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044c \u043d\u0430\u0434 \u0436\u0438\u0437\u043d\u0435\u043d\u043d\u044b\u043c \u0446\u0438\u043a\u043b\u043e\u043c \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f, \u0442\u043e\u043d\u043a\u0430\u044f \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0430 prefetch, \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u044c \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u043b\u044e\u0431\u0443\u044e \u043b\u043e\u0433\u0438\u043a\u0443 \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u044f (\u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u043e\u0442\u043b\u043e\u0436\u0435\u043d\u043d\u044b\u0439 ack \u043f\u043e\u0441\u043b\u0435 \u0437\u0430\u0432\u0435\u0440\u0448\u0435\u043d\u0438\u044f \u0446\u0435\u043f\u043e\u0447\u043a\u0438 \u0434\u0435\u0439\u0441\u0442\u0432\u0438\u0439). \u041d\u0435\u0442 \u043b\u0438\u0448\u043d\u0438\u0445 \u043c\u0435\u0442\u0430\u0434\u0430\u043d\u043d\u044b\u0445 \u0432 \u0442\u0435\u043b\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u2014 \u0431\u0440\u043e\u043a\u0435\u0440 \u043f\u0435\u0440\u0435\u0434\u0430\u0451\u0442 \u0440\u043e\u0432\u043d\u043e \u0442\u043e, \u0447\u0442\u043e \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u043b \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440. \u0410\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0441\u0442\u044c \u043d\u0430\u0442\u0438\u0432\u043d\u0430\u044f, \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u043d\u0430 asyncio \u0431\u0435\u0437 \u043a\u043e\u0441\u0442\u044b\u043b\u0435\u0439.\u041f\u0440\u043e\u0431\u043b\u0435\u043c\u044b\u041a\u0430\u0436\u0434\u0430\u044f \u00ab\u043f\u043b\u044e\u0448\u043a\u0430\u00bb \u0434\u0435\u043b\u0430\u043b\u0430\u0441\u044c \u0432\u0440\u0443\u0447\u043d\u0443\u044e \u0438 \u0441\u043e \u0432\u0440\u0435\u043c\u0435\u043d\u0435\u043c \u043e\u0431\u044a\u0451\u043c \u0438\u043d\u0444\u0440\u0430\u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430 \u0440\u0430\u0437\u0440\u043e\u0441\u0441\u044f. \u0414\u0435\u0441\u044f\u0442\u043a\u0438 \u0441\u0442\u0440\u043e\u043a \u0434\u043b\u044f \u0434\u0435\u043a\u043b\u0430\u0440\u0430\u0446\u0438\u0438 \u043e\u0447\u0435\u0440\u0435\u0434\u0435\u0439, \u043b\u043e\u0433\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 reconnect\u2011\u0446\u0438\u043a\u043b\u0430, \u0441\u043e\u0433\u043b\u0430\u0441\u043e\u0432\u0430\u043d\u0438\u0435 \u0444\u043e\u0440\u043c\u0430\u0442\u0430 trace\u2011\u0437\u0430\u0433\u043e\u043b\u043e\u0432\u043a\u043e\u0432 \u043c\u0435\u0436\u0434\u0443 \u0441\u0435\u0440\u0432\u0438\u0441\u0430\u043c\u0438. Healthcheck, \u0445\u043e\u0442\u044c \u0438 \u0431\u044b\u043b \u0441\u043e\u0437\u0434\u0430\u043d \u0432\u0440\u0443\u0447\u043d\u0443\u044e, \u0442\u0440\u0435\u0431\u043e\u0432\u0430\u043b \u0430\u043a\u043a\u0443\u0440\u0430\u0442\u043d\u043e\u0441\u0442\u0438: \u043d\u0443\u0436\u043d\u043e \u0431\u044b\u043b\u043e \u043e\u0442\u0441\u043b\u0435\u0436\u0438\u0432\u0430\u0442\u044c \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u0435 \u043d\u0435 \u0442\u043e\u043b\u044c\u043a\u043e TCP-\u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f, \u043d\u043e \u0438 \u043e\u0442\u043a\u0440\u044b\u0442\u043e\u0433\u043e \u043a\u0430\u043d\u0430\u043b\u0430.\u0420\u0435\u0448\u0435\u043d\u0438\u0435 \u21163: FastStream \u2014 \u0437\u043e\u043b\u043e\u0442\u0430\u044f \u0441\u0435\u0440\u0435\u0434\u0438\u043d\u0430\u041e\u0441\u043d\u043e\u0432\u043d\u0430\u044f \u0438\u0434\u0435\u044fFastStream \u2014 \u043d\u0430\u0434\u0441\u0442\u0440\u043e\u0439\u043a\u0430 \u043d\u0430\u0434 aio-pika (\u0430 \u0442\u0430\u043a\u0436\u0435 \u043d\u0430\u0434 NATS, Kafka), \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0434\u0430\u0451\u0442 \u0434\u0435\u043a\u043b\u0430\u0440\u0430\u0442\u0438\u0432\u043d\u044b\u0439 \u0441\u0442\u0438\u043b\u044c \u043e\u043f\u0438\u0441\u0430\u043d\u0438\u044f consumer\u2019\u043e\u0432, lifespan\u2011\u0445\u0443\u043a\u0438, \u0432\u0441\u0442\u0440\u043e\u0435\u043d\u043d\u044b\u0435 \u043c\u0435\u0445\u0430\u043d\u0438\u0437\u043c\u044b: healthcheck-\u044d\u043d\u0434\u043f\u043e\u0438\u043d\u0442, OpenTelemetry-\u0438\u043d\u0442\u0435\u0433\u0440\u0430\u0446\u0438\u044f, \u043c\u0435\u0442\u0440\u0438\u043a\u0438 Prometheus. \u041f\u043e \u0441\u0443\u0442\u0438, \u044d\u0442\u043e aio-pika, \u043e\u0431\u0451\u0440\u043d\u0443\u0442\u0430\u044f \u0432 \u043b\u0443\u0447\u0448\u0438\u0435 \u043f\u0440\u0430\u043a\u0442\u0438\u043a\u0438, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043c\u044b \u0441\u0430\u043c\u0438 \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u044b\u0432\u0430\u043b\u0438 \u0440\u0443\u043a\u0430\u043c\u0438 \u0432 \u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0435\u043c \u0440\u0435\u0448\u0435\u043d\u0438\u0438. \u041c\u0435\u0445\u0430\u043d\u0438\u0437\u043c retry \u043e\u043f\u0438\u0441\u0430\u043d \u043a\u0430\u043a \u043f\u0440\u0438\u043c\u0435\u0440 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u044f middleware.\u0427\u0442\u043e \u043f\u043e\u0448\u043b\u043e \u0442\u0430\u043aHealthcheck \u0438\u0437 \u043a\u043e\u0440\u043e\u0431\u043a\u0438 \u2014 \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u0443\u043a\u0430\u0437\u0430\u0442\u044c FastStream \u043e\u0431\u044a\u0435\u043a\u0442 \u0432 ASGI-\u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0438 (\u0447\u0435\u0440\u0435\u0437 AsgiFastStream), \u0438 \u043d\u0430 \/health \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u0442\u0441\u044f \u0441\u0442\u0430\u0442\u0443\u0441 \u0431\u0440\u043e\u043a\u0435\u0440\u0430.Lifespan \u2014 \u043c\u0435\u043d\u0435\u0434\u0436\u0435\u0440 \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u0430 \u0443\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442 \u0437\u0430\u043f\u0443\u0441\u043a\u043e\u043c \u0438 \u043a\u043e\u0440\u0440\u0435\u043a\u0442\u043d\u043e\u0439 \u043e\u0441\u0442\u0430\u043d\u043e\u0432\u043a\u043e\u0439 consumer\u2019\u043e\u0432, \u043f\u043e\u0432\u0442\u043e\u0440\u043d\u044b\u043c\u0438 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f\u043c\u0438. \u041d\u0435 \u043d\u0443\u0436\u043d\u043e \u043f\u0438\u0441\u0430\u0442\u044c \u0441\u0432\u043e\u0438 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u0438 \u0441\u0438\u0433\u043d\u0430\u043b\u043e\u0432. \u042d\u0442\u043e \u043a\u0430\u0441\u0430\u043b\u043e\u0441\u044c \u043d\u0435 &#8230;<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[],"tags":[],"class_list":["post-478096","post","type-post","status-publish","format-standard","hentry"],"_links":{"self":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/478096","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=478096"}],"version-history":[{"count":0,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/478096\/revisions"}],"wp:attachment":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=478096"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=478096"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=478096"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}