committed by
GitHub
1 changed files with 94 additions and 0 deletions
@ -0,0 +1,94 @@ |
|||
# バックグラウンドタスク |
|||
|
|||
レスポンスを返した *後に* 実行されるバックグラウンドタスクを定義できます。 |
|||
|
|||
これは、リクエスト後に処理を開始する必要があるが、クライアントがレスポンスを受け取る前に処理を終える必要のない操作に役立ちます。 |
|||
|
|||
これには、たとえば次のものが含まれます。 |
|||
|
|||
* 作業実行後のメール通知: |
|||
* メールサーバーへの接続とメールの送信は「遅い」(数秒) 傾向があるため、すぐにレスポンスを返し、バックグラウンドでメール通知ができます。 |
|||
* データ処理: |
|||
* たとえば、時間のかかる処理を必要とするファイル受信時には、「受信済み」(HTTP 202) のレスポンスを返し、バックグラウンドで処理できます。 |
|||
|
|||
## `BackgroundTasks` の使用 |
|||
|
|||
まず初めに、`BackgroundTasks` をインポートし、` BackgroundTasks` の型宣言と共に、*path operation 関数* のパラメーターを定義します: |
|||
|
|||
```Python hl_lines="1 13" |
|||
{!../../../docs_src/background_tasks/tutorial001.py!} |
|||
``` |
|||
|
|||
**FastAPI** は、`BackgroundTasks` 型のオブジェクトを作成し、そのパラメーターに渡します。 |
|||
|
|||
## タスク関数の作成 |
|||
|
|||
バックグラウンドタスクとして実行される関数を作成します。 |
|||
|
|||
これは、パラメーターを受け取ることができる単なる標準的な関数です。 |
|||
|
|||
これは `async def` または通常の `def` 関数であり、**FastAPI** はこれを正しく処理します。 |
|||
|
|||
ここで、タスク関数はファイル書き込みを実行します (メール送信のシミュレーション)。 |
|||
|
|||
また、書き込み操作では `async` と `await` を使用しないため、通常の `def` で関数を定義します。 |
|||
|
|||
```Python hl_lines="6-9" |
|||
{!../../../docs_src/background_tasks/tutorial001.py!} |
|||
``` |
|||
|
|||
## バックグラウンドタスクの追加 |
|||
|
|||
*path operations 関数* 内で、`.add_task()` メソッドを使用してタスク関数を *background tasks* オブジェクトに渡します。 |
|||
|
|||
```Python hl_lines="14" |
|||
{!../../../docs_src/background_tasks/tutorial001.py!} |
|||
``` |
|||
|
|||
`.add_task()` は以下の引数を受け取ります: |
|||
|
|||
* バックグラウンドで実行されるタスク関数 (`write_notification`)。 |
|||
* タスク関数に順番に渡す必要のある引数の列 (`email`)。 |
|||
* タスク関数に渡す必要のあるキーワード引数 (`message="some notification"`)。 |
|||
|
|||
## 依存性注入 |
|||
|
|||
`BackgroundTasks` の使用は依存性注入システムでも機能し、様々な階層 (*path operations 関数*、依存性 (依存可能性)、サブ依存性など) で `BackgroundTasks` 型のパラメーターを宣言できます。 |
|||
|
|||
**FastAPI** は、それぞれの場合の処理方法と同じオブジェクトの再利用方法を知っているため、すべてのバックグラウンドタスクがマージされ、バックグラウンドで後で実行されます。 |
|||
|
|||
```Python hl_lines="13 15 22 25" |
|||
{!../../../docs_src/background_tasks/tutorial002.py!} |
|||
``` |
|||
|
|||
この例では、レスポンスが送信された *後* にメッセージが `log.txt` ファイルに書き込まれます。 |
|||
|
|||
リクエストにクエリがあった場合、バックグラウンドタスクでログに書き込まれます。 |
|||
|
|||
そして、*path operations 関数* で生成された別のバックグラウンドタスクは、`email` パスパラメータを使用してメッセージを書き込みます。 |
|||
|
|||
## 技術的な詳細 |
|||
|
|||
`BackgroundTasks` クラスは、<a href="https://www.starlette.io/background/" class="external-link" target="_blank">`starlette.background`</a>から直接取得されます。 |
|||
|
|||
これは、FastAPI に直接インポート/インクルードされるため、`fastapi` からインポートできる上に、`starlette.background`から別の `BackgroundTask` (末尾に `s` がない) を誤ってインポートすることを回避できます。 |
|||
|
|||
`BackgroundTasks`のみを使用することで (`BackgroundTask` ではなく)、`Request` オブジェクトを直接使用する場合と同様に、それを *path operations 関数* パラメーターとして使用し、**FastAPI** に残りの処理を任せることができます。 |
|||
|
|||
それでも、FastAPI で `BackgroundTask` を単独で使用することは可能ですが、コード内でオブジェクトを作成し、それを含むStarlette `Response` を返す必要があります。 |
|||
|
|||
詳細については、<a href="https://www.starlette.io/background/" class="external-link" target="_blank">バックグラウンドタスクに関する Starlette の公式ドキュメント</a>を参照して下さい。 |
|||
|
|||
## 警告 |
|||
|
|||
大量のバックグラウンド計算が必要であり、必ずしも同じプロセスで実行する必要がない場合 (たとえば、メモリや変数などを共有する必要がない場合)、<a href="https://www.celeryproject.org/" class="external-link" target="_blank">Celery</a> のようなより大きな他のツールを使用するとメリットがあるかもしれません。 |
|||
|
|||
これらは、より複雑な構成、RabbitMQ や Redis などのメッセージ/ジョブキューマネージャーを必要とする傾向がありますが、複数のプロセス、特に複数のサーバーでバックグラウンドタスクを実行できます。 |
|||
|
|||
例を確認するには、[Project Generators](../project-generation.md){.internal-link target=_blank} を参照してください。これらにはすべて、Celery が構築済みです。 |
|||
|
|||
ただし、同じ **FastAPI** アプリから変数とオブジェクトにアクセスする必要がある場合、または小さなバックグラウンドタスク (電子メール通知の送信など) を実行する必要がある場合は、単に `BackgroundTasks` を使用できます。 |
|||
|
|||
## まとめ |
|||
|
|||
`BackgroundTasks` をインポートして、*path operations 関数* や依存関係のパラメータに `BackgroundTasks`を使用し、バックグラウンドタスクを追加して下さい。 |
Loading…
Reference in new issue