BigQuery to MongoDB 템플릿

BigQuery to MongoDB 템플릿은 BigQuery에서 행을 읽고 이를 MongoDB에 문서로 쓰는 일괄 파이프라인입니다. 현재 각 행은 문서로 저장됩니다.

파이프라인 요구사항

  • 소스 BigQuery 테이블이 있어야 합니다.
  • Dataflow 작업자 머신에서 대상 MongoDB 인스턴스에 액세스할 수 있어야 합니다.

템플릿 매개변수

매개변수 설명
mongoDbUri mongodb+srv://:@ 형식의 MongoDB 연결 URI입니다.
database 컬렉션을 저장하기 위한 MongoDB의 데이터베이스입니다. 예를 들면 my-db입니다.
collection MongoDB 데이터베이스의 컬렉션 이름입니다. 예를 들면 my-collection입니다.
inputTableSpec 데이터를 읽을 BigQuery 테이블입니다. 예를 들면 bigquery-project:dataset.input_table입니다.

템플릿 실행

콘솔

  1. Dataflow 템플릿에서 작업 만들기 페이지로 이동합니다.
    2. 템플릿에서 작업 만들기로 이동
  2. 작업 이름 필드에 고유한 작업 이름을 입력합니다.
  3. (선택사항): 리전 엔드포인트의 드롭다운 메뉴에서 값을 선택합니다. 기본 리전은 us-central1입니다.

    Dataflow 작업을 실행할 수 있는 리전 목록은 Dataflow 위치를 참조하세요.

  4. Dataflow 템플릿 드롭다운 메뉴에서 the BigQuery to MongoDB template을 선택합니다.
  5. 제공된 매개변수 필드에 매개변수 값을 입력합니다.
  6. 작업 실행을 클릭합니다.

gcloud

셸 또는 터미널에서 템플릿을 실행합니다.

  gcloud dataflow flex-template run JOB_NAME \
      --project=PROJECT_ID \
      --region=REGION_NAME \
      --template-file-gcs-location=gs://dataflow-templates-REGION_NAME/VERSION/flex/BigQuery_to_MongoDB \
      --parameters \
  inputTableSpec=INPUT_TABLE_SPEC,\
  mongoDbUri=MONGO_DB_URI,\
  database=DATABASE,\
  collection=COLLECTION

다음을 바꿉니다.

  • PROJECT_ID: Dataflow 작업을 실행하려는 Google Cloud 프로젝트 ID입니다.
  • JOB_NAME: 선택한 고유한 작업 이름입니다.
  • REGION_NAME: Dataflow 작업을 배포할 리전입니다(예: us-central1).
  • VERSION: 사용할 템플릿 버전입니다.

    다음 값을 사용할 수 있습니다.

  • INPUT_TABLE_SPEC: 소스 BigQuery 테이블 이름
  • MONGO_DB_URI: MongoDB URI
  • DATABASE: MongoDB 데이터베이스입니다.
  • COLLECTION: MongoDB 컬렉션

API

REST API를 사용하여 템플릿을 실행하려면 HTTP POST 요청을 전송합니다. API 및 승인 범위에 대한 자세한 내용은 projects.templates.launch를 참조하세요.

  POST https://dataflow.googleapis.com/v1b3/projects/PROJECT_ID/locations/LOCATION/flexTemplates:launch
  {
     "launch_parameter": {
        "jobName": "JOB_NAME",
        "parameters": {
            "inputTableSpec": "INPUT_TABLE_SPEC",
            "mongoDbUri": "MONGO_DB_URI",
            "database": "DATABASE",
            "collection": "COLLECTION"
        },
        "containerSpecGcsPath": "gs://dataflow-templates-LOCATION/VERSION/flex/BigQuery_to_MongoDB",
     }
  }

다음을 바꿉니다.

  • PROJECT_ID: Dataflow 작업을 실행하려는 Google Cloud 프로젝트 ID입니다.
  • JOB_NAME: 선택한 고유한 작업 이름입니다.
  • LOCATION: Dataflow 작업을 배포할 리전입니다(예: us-central1).
  • VERSION: 사용할 템플릿 버전입니다.

    다음 값을 사용할 수 있습니다.

  • INPUT_TABLE_SPEC: 소스 BigQuery 테이블 이름
  • MONGO_DB_URI: MongoDB URI
  • DATABASE: MongoDB 데이터베이스입니다.
  • COLLECTION: MongoDB 컬렉션

다음 단계