管理串流

本頁面說明如何使用 Datastream API 執行下列操作：

  • 建立串流
  • 取得串流和串流物件的相關資訊
  • 啟動、暫停、繼續及修改串流，以及啟動和停止串流物件的補充作業，藉此更新串流
  • 復原永久失敗的串流
  • 為 Oracle 串流啟用大型物件串流
  • 刪除串流

使用 Datastream API 的方法有兩種。您可以發出 REST API 呼叫，也可以使用 Google Cloud CLI (CLI)。

如要瞭解如何使用 Google Cloud CLI 管理 Datastream 串流，請參閱 gcloud CLI Datastream 串流。

建立串流

本節將說明如何建立串流，用於將資料從來源傳輸至目的地。以下範例並非完整說明，而是著重於 Datastream 的特定功能。如要解決特定用途，請搭配使用這些範例和 Datastream API 參考文件。

本節涵蓋下列用途：

範例 1：將特定物件串流至 BigQuery

在本範例中，您將瞭解如何：

  • 從 MySQL 串流至 BigQuery
  • 在串流中加入一組物件
  • 將串流的寫入模式定義為僅附加
  • 回填串流中包含的所有物件

以下要求會從 schema1 提取所有資料表，並從 schema2 提取兩個特定資料表：tableA 和 tableC。這些事件會寫入 BigQuery 的資料集。

要求未包含 customerManagedEncryptionKey 參數，因此系統會使用 Google Cloud 內部金鑰管理系統加密資料，而非 CMEK。

與執行歷史補充作業 (或快照) 相關聯的 backfillAll 參數會設為空白字典 ({})，這表示 Datastream 會回填串流中所有資料表的歷來資料。

REST