セロリ

logfire.instrument_celery() メソッドは、Celeryワーカーが実行するタスクごとにスパンを作成します。

インストール

额外的芹菜 を使用して logfire をインストールする:

{{ install_logfire(extras=['芹菜']) }}

使い方

Celeryを実行するにはMessage Agentが必要です。この例では、dockerコンテナ上でRabbitMQを実行します。次のように実行できます。

docker run -d --hostname my-rabbit \
    --name some-rabbit \
    # -e RABBITMQ_DEFAULT_USER=user \
    # -e RABBITMQ_DEFAULT_PASS=password \
    rabbitmq:3-management

以下に、セロリを使用する最小の例を示します。celery -A tasks worker --loglevel=info を使用して実行できます:

logfire. configure()

@works_process_in it. connect(弱い=False) def in it_celery_tracing(args,*kwargs): ログファイア.インストゥルメント_セロリ()

アプリ=Celery("タスク",ブローカー="pyamqp://localhost//")#(1)!

タスク@app. task def add(x, y): x+yを返す

追加ディレイ(42,50) ```

1. 使用 pip install pyamqp 安装 pyamqp。

logfire.instrument_celery() 传递给 CeleryInstrumentor().instrument() 方法。

---

本文总阅读量次