Method: indexing.datasources.items.poll

インデックス キューから予約されていないアイテムをポーリングし、優先度が最も高い ItemStatus から最も古いタイムスタンプを持つアイテムから順に、セットを予約済みとしてマークします。優先順位は次のとおりです。

ERROR

MODIFIED

NEW_ITEM

ACCEPTED

アイテムを予約すると、他のスレッドからのポーリングで重複するセットが作成されなくなります。

予約済みアイテムを処理した後、クライアントは index, を呼び出すか、タイプ REQUEUE. で push を呼び出して、アイテムを予約解除状態に戻す必要があります。

更新メソッドや push メソッドが呼び出されなくても、アイテムは 4 時間後に自動的に利用可能（予約解除）になります。

この API を実行するには、管理者またはサービス アカウントが必要です。使用されるサービス アカウントは、対応するデータソースでホワイトリストに登録されているアカウントです。

HTTP リクエスト

POST https://cloudsearch.googleapis.com/v1/indexing/{name=datasources/*}/items:poll

この URL は gRPC Transcoding 構文を使用します。

パスパラメータ

パラメータ
name

string

アイテムをポーリングするデータソースの名前。形式: datasources/{sourceId}

リクエストの本文

リクエストの本文には、次の構造のデータが含まれます。

JSON 表現 
{
  "connectorName": string,
  "statusCodes": [
    enum (ItemStatus.Code)
  ],
  "limit": integer,
  "queue": string,
  "debugOptions": {
    object (DebugOptions)
  }
}
フィールド
connectorName

string

この呼び出しを行うコネクタの名前。

形式: datasources/{sourceId}/connectors/{id}
statusCodes[]

enum (ItemStatus.Code)

ポーリングするアイテムを、これらのステータスを持つアイテムに制限します。
limit

integer

返されるアイテムの最大数。

最大値は 100、デフォルト値は 20 です。
queue

string

アイテムを取得するキュー名。指定しない場合、items.poll は「default」キューから取得します。最大で 100 文字です。
debugOptions

object (DebugOptions)

一般的なデバッグ オプション。

レスポンスの本文

成功すると、レスポンスの本文に次の構造のデータが含まれます。

JSON 表現 
{
  "items": [
    {
      object (Item)
    }
  ]
}
フィールド
items[]

object (Item)

コネクタが処理できるキュー内のアイテムのセット。

これらのアイテムには、次のフィールドのサブセットが入力されます。

version

metadata.hash

structuredData.hash

content.hash

payload

status

queue

認可スコープ

以下のいずれかの OAuth スコープが必要です。

  • https://www.googleapis.com/auth/cloud_search.indexing
  • https://www.googleapis.com/auth/cloud_search

詳しくは、認可ガイドをご覧ください。