翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
# ワーカーに送信されるデータオブジェクトのフローを制御する
作成するラベル付けジョブのタイプに応じて、Amazon SageMaker Ground Truth は、バッチまたはストリーミング方式でデータオブジェクトをワーカーに送信します。ワーカーへのデータオブジェクトのフローは、次の方法で制御できます。
+ どちらのタイプのラベル付けジョブでも、ラベル付けジョブの実行中の特定の時点で、すべてのワーカーが使用できるデータオブジェクトの総数を、`MaxConcurrentTaskCount` を使用して制御できます。
+ ストリーミングラベル付けジョブの場合、ラベル付けジョブに関連付けられた Amazon SQS に送信されるデータオブジェクトの数を監視および制御することで、ワーカーへのデータオブジェクトのフローを制御できます。
これらのオプションの詳細については、次のセクションを参照してください。
**Topics**
+ [maxConcurrentTaskCount を使用してデータオブジェクトのフローを制御する](#sms-batching-maxconcurrenttaskcount)
+ [Amazon SQS を使用して、ストリーミングラベル付けジョブへのデータオブジェクトのフローを制御する](#sms-batching-streaming-sqs)
## maxConcurrentTaskCount を使用してデータオブジェクトのフローを制御する
[https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_HumanTaskConfig.html#sagemaker-Type-HumanTaskConfig-MaxConcurrentTaskCount](https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_HumanTaskConfig.html#sagemaker-Type-HumanTaskConfig-MaxConcurrentTaskCount) には、ワーカーポータルタスクキューで一度に使用できるデータオブジェクトの最大数を定義します。コンソールを使用する場合、このパラメータは 1,000 に設定されます。`CreateLabelingJob` を使用した場合は、このパラメータを 1～5,000 の範囲の任意の整数に設定できます。
次の例を使用して、ワーカーポータル UI のタスクキューでワーカーに表示されるタスクを、マニフェストファイルのエントリ数、`NumberOfHumanWorkersPerDataObject`、および `MaxConcurrentTaskCount` によってどのように定義するかを説明します。
1. エントリ数が 600 の入力マニフェストファイルがあるとします。
1. `NumberOfHumanWorkersPerDataObject` を使用して、入力マニフェストファイルの各エントリにラベルを付けるヒューマンワーカーの数を定義できます。この例で、`NumberOfHumanWorkersPerDataObject` に 3 を設定した場合、入力マニフェストファイルのエントリごとに 3 つのタスクが作成されます。また、ラベル付けの完了を記録するには、少なくとも 3 人のワーカーがオブジェクトをラベル付けする必要があります。その結果、合計 1,800 のタスク (600 x 3) が作成され、ワーカーによって実行されます。
1. ワーカーポータル UI で、キュー内のタスクをワーカーに 100 件ずつ表示したいとします。それには、`MaxConcurrentTaskCount` を 100 に設定します。すると Ground Truth は、ワーカーポータルタスクのキューに、各ワーカーに対して 100 件までタスクを入れます。
1. その後の処理は、作成するラベル付けジョブのタイプ、およびストリーミングのラベル付けジョブかどうかによって異なります。
+ **ストリーミングラベル付けジョブ**: ワーカーが使用できるオブジェクトの総数が `MaxConcurrentTaskCount` に等しい限り、Amazon SNS を使用してリアルタイムで送信する、入力マニフェストファイル上のすべての残りのデータセットオブジェクトが、Amazon SQS キューに配置されます。ワーカーが使用できるオブジェクトの合計数が `NumberOfHumanWorkersPerDataObject` から `MaxConcurrentTaskCount` を引いた数を下回った場合、キューから送られる新しいデータオブジェクトを使用して、リアルタイムでワーカーに送信される `NumberOfHumanWorkersPerDataObject` タスクが作成されます。
+ **非ストリーミングラベル付けジョブ**: ワーカーが 1 セットのオブジェクトのラベル付けを完了すると、最大 `MaxConcurrentTaskCount` 回、新しいタスクの `NumberOfHumanWorkersPerDataObject` の数がワーカーに送信されます。このプロセスは、入力マニフェストファイル内のすべてのデータオブジェクトにラベルが付けられるまで繰り返されます。
## Amazon SQS を使用して、ストリーミングラベル付けジョブへのデータオブジェクトのフローを制御する
ストリーミングラベル付けジョブを作成すると、Amazon SQS キューがアカウントに自動的に作成されます。データオブジェクトは、ワーカーに送信されたオブジェクトの総数が `MaxConcurrentTaskCount` を上回っている場合にのみ Amazon SQS キューに追加されます。それ以外の場合、オブジェクトはワーカーに直接送信されます。
このキューを使用して、ラベル付けジョブへのデータオブジェクトのフローを管理できます。詳細については[Amazon SQS キューを使用してラベル付けリクエストを管理する](sms-streaming-how-it-works-sqs.md)を参照してください。