Method: indexing.datasources.items.poll

색인 생성 큐에서 예약되지 않은 항목을 폴링하고 집합을 예약된 것으로 표시합니다. 이때 우선순위가 가장 높은 ItemStatus에서 가장 오래된 타임스탬프가 있는 항목부터 시작합니다. 우선순위는 다음과 같습니다.

ERROR

MODIFIED

NEW_ITEM

ACCEPTED

항목을 예약하면 다른 스레드의 폴링이 겹치는 세트를 만들 수 없습니다.

예약된 항목을 처리한 후 클라이언트는 index,를 호출하거나 REQUEUE. 유형으로 push를 호출하여 항목을 예약되지 않은 상태로 다시 전환해야 합니다.

업데이트 또는 푸시 메서드가 호출되지 않아도 4시간 후에는 항목이 자동으로 사용 가능 (예약되지 않음)됩니다.

이 API를 실행하려면 관리자 또는 서비스 계정이 필요합니다. 사용된 서비스 계정은 해당 데이터 소스에서 허용된 계정입니다.

HTTP 요청

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

URL은 gRPC 트랜스코딩 구문을 사용합니다.

경로 매개변수

매개변수
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이 '기본' 대기열에서 가져옵니다. 최대 길이는 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

자세한 내용은 승인 가이드를 참고하세요.