哨兵 - 同时对数烧瓶和哨兵/同一DSN

Question

编辑：标题并添加了一些代码示例。

我正在尝试研究如何使用相同的DSN将芹菜工人和烧瓶日志记录发送到哨兵。

设置如下：

• Flask 应用将异步任务发送给 Celery 工作人员。
• Flask 和 Celery worker 分别在链接的 Docker 容器中运行
• 我们使用应用程序工厂模式在 __init__.py 文件中动态创建应用实例，因此这就是 Celery 和 Sentry 设置当前发生的地方：

(出于演示目的，代码已简化。

celery = Celery(__name__, broker=config[config_name].CELERY_BROKER_URL)
client = Client(dsn={my_dsn}, transport=HTTPTransport, )
sentry = Sentry(client=client)
def create_app(config_filename): 
    app = Flask(__name__)
    app.config.from_pyfile(config_filename)
    celery.conf.update(app.config)
    # https://docs.getsentry.com/hosted/clients/python/integrations/flask/#extended-setup :
    sentry.init_app(app, logging=True, level=logging.INFO, )
    # https://docs.getsentry.com/hosted/clients/python/integrations/celery/ :
    register_logger_signal(client, loglevel=logging.INFO)
    register_signal(client)
    return app

通过遵循哨兵芹菜的说明，哨兵(用他们自己的话说("劫持芹菜错误处理"，并且效果很好。但是，这会在此过程中删除 Flask 错误处理。

有没有办法注册两个记录器(烧瓶和芹菜(，以便它们都将日志条目发送到哨兵？还是应该在 Celery 容器中运行的单独celery_worker.py文件中进行 Celery 注册？

Answer 1

我设法这样做：

app = Flask(__name__)
celery = Celery(app.import_name, broker=app.config['CELERY_BROKER_URL'], backend=app.config['CELERY_RESULT_BACKEND'], worker_send_task_events=True, task_send_sent_event=True)
celery.conf.update(app.config)
client = Client(dsn={my_dsn})
sentry = Sentry(app, dsn={my_dsn})
register_logger_signal(client)
register_logger_signal(client, loglevel=logging.INFO)
register_signal(client)
register_signal(client, ignore_expected=True)