將 PostgreSQL 資料載入 BigQuery
您可以使用 PostgreSQL 適用的 BigQuery 資料移轉服務連接器,將資料從 PostgreSQL 載入至 BigQuery。連接器支援在內部部署環境、Cloud SQL 中代管的 PostgreSQL 執行個體,以及其他公用雲端供應商 (例如 Amazon Web Services (AWS) 和 Microsoft Azure)。您可以使用 BigQuery 資料移轉服務,安排週期性移轉工作,將最新資料從 PostgreSQL 新增至 BigQuery。
限制
PostgreSQL 資料移轉作業有下列限制:
- 單一 PostgreSQL 資料庫同時執行的轉移作業數量上限,取決於 PostgreSQL 資料庫支援的並行連線數量上限。並行轉移作業的數量應限制在 PostgreSQL 資料庫支援的並行連線數量上限以下。
- 在 PostgreSQL 中,部分資料類型會對應至 BigQuery 中的字串類型,以免資料遺失。舉例來說,在 PostgreSQL 中定義的數值類型,如果沒有定義精確度和小數位數,就會對應至 BigQuery 中的字串類型。
事前準備
- 在 PostgreSQL 資料庫中建立使用者。
- 確認您已完成啟用 BigQuery 資料移轉服務的一切必要動作。
- 請建立 BigQuery 資料集來儲存您的資料。
- 請確認您具備必要角色,才能完成本文中的任務。
必要的角色
如果您想要為 Pub/Sub 設定移轉執行通知,請確認您具有 pubsub.topics.setIamPolicy
身分與存取權管理 (IAM) 權限。如果您只想設定電子郵件通知,則不需要擁有 Pub/Sub 權限。詳情請參閱「BigQuery 資料移轉服務執行通知」。
如要取得建立 PostgreSQL 資料移轉作業所需的權限,請要求管理員授予您專案的 BigQuery 管理員 (roles/bigquery.admin
) IAM 角色。如要進一步瞭解如何授予角色,請參閱「管理專案、資料夾和機構的存取權」。
這個預先定義的角色包含建立 PostgreSQL 資料移轉作業所需的權限。如要查看確切的必要權限,請展開「必要權限」部分:
所需權限
如要建立 PostgreSQL 資料移轉作業,必須具備下列權限:
bigquery.transfers.update
bigquery.datasets.get
網路連線數
如果 PostgreSQL 資料庫連線無法使用公開 IP 位址,您必須設定網路附件。
如需有關必要網路設定的詳細操作說明,請參閱下列文件:
- 如果您要從 Cloud SQL 轉移資料,請參閱「設定 Cloud SQL 執行個體存取權」。
- 如果您是從 AWS 轉移,請參閱「設定 AWS-Google Cloud VPN 和網路附件」一文。
- 如果您要從 Azure 轉移,請參閱「設定 Azure-Google Cloud VPN 和網路附件」。
設定 PostgreSQL 資料移轉
選取下列選項之一:
控制台
前往「資料移轉」頁面。
按一下
「建立移轉作業」。在「Source type」(來源類型) 部分,針對「Source」(來源) 選取「PostgreSQL」。
在「Transfer config name」(轉移設定名稱) 部分,「Display name」(顯示名稱) 請輸入移轉作業的名稱。移轉作業名稱可以是任意值,日後需要修改移轉作業時能夠據此識別。
在「Schedule options」(排程選項) 部分執行下列操作:
- 選取重複頻率。如果選取「小時」、「天」(預設)、「週」或「月」選項,則必須一併指定頻率。您也可以選取「Custom」(自訂) 選項,建立更具體的重複頻率。如果選取「On-demand」(隨選)選項,這項資料移轉作業會在您手動觸發後執行。
- 視情況選取「Start now」(立即開始) 或「Start at set time」(在所設時間開始執行) 選項,並提供開始日期和執行時間。
在「Destination settings」(目的地設定) 部分,「Dataset」(資料集) 請選取您為了儲存資料而建立的資料集,或是按一下「Create new dataset」(建立新資料集),然後建立一個用來做為目的地資料集的資料集。
在「Data source details」(資料來源詳細資料) 部分執行下列操作:
- 在「Network attachment」(網路連結) 部分選取現有的網路連結,或是點選「Create Network Attachment」(建立網路連結)。詳情請參閱本文件的「網路連線」一節。
- 在「Host」 部分,輸入 PostgreSQL 資料庫伺服器的主機名稱或 IP 位址。
- 在「Port number」(通訊埠編號) 中,輸入 PostgreSQL 資料庫伺服器的通訊埠編號。
- 在「資料庫名稱」中輸入 PostgreSQL 資料庫的名稱。
- 在「使用者名稱」中,輸入啟動 PostgreSQL 資料庫連線的 PostgreSQL 使用者名稱。
- 在「密碼」部分,輸入啟動 PostgreSQL 資料庫連線的 PostgreSQL 使用者密碼。
如要轉移 PostgreSQL 物件,請執行下列任一操作:
- 按一下「Browse」選取轉移作業所需的 PostgreSQL 資料表,然後點選「Select」。
- 手動輸入要轉移的 PostgreSQL 物件中資料表名稱。
選用:在「Service account」(服務帳戶) 選單中,指定自訂服務帳戶授權移轉作業。請確認所使用的服務帳戶具備所有必要角色和權限。詳情請參閱「以服務帳戶身分轉移擁有者」一文。
選用:在「Notification options」(通知選項) 專區,執行下列操作:
按一下 [儲存]。
bq
輸入 bq mk
指令並提供轉移建立標記 --transfer_config
:
bq mk --transfer_config --project_id=PROJECT_ID --data_source=DATA_SOURCE --display_name=DISPLAY_NAME --target_dataset=DATASET --params='PARAMETERS'
更改下列內容:
- PROJECT_ID (選用):您的 Google Cloud 專案 ID。如未提供
--project_id
標記指定特定專案,系統會使用預設專案。 - DATA_SOURCE:資料來源,即
postgresql
。 - DISPLAY_NAME:資料移轉設定的顯示名稱。移轉作業名稱可以是任意值,日後需要修改移轉作業時能夠據此識別。
- DATASET:資料移轉設定的目標資料集。
PARAMETERS:已建立移轉設定的 JSON 格式參數。例如:
--params='{"param":"param_value"}'
。以下是 PostgreSQL 轉移作業的參數:networkAttachment
(選用):連線至 PostgreSQL 資料庫的網路附件名稱。connector.database
:PostgreSQL 資料庫的名稱。connector.endpoint.host
:資料庫的主機名稱或 IP 位址。connector.endpoint.port
:資料庫的通訊埠號碼。connector.authentication.username
:資料庫使用者的使用者名稱。connector.authentication.password
:資料庫使用者的密碼。assets
:從 PostgreSQL 資料庫傳輸的 PostgreSQL 資料表名稱清單。
舉例來說,下列指令會建立名為 My Transfer
的 PostgreSQL 轉移作業:
bq mk --transfer_config --target_dataset=mydataset --data_source=postgresql --display_name='My Transfer' --params='{"assets":["DB1/PUBLIC/DEPARTMENT","DB1/PUBLIC/EMPLOYEES"], "connector.authentication.username": "User1", "connector.authentication.password":"ABC12345", "connector.database":"DB1", "connector.endpoint.host":"192.168.0.1", "connector.endpoint.port":5432}'
API
請使用 projects.locations.transferConfigs.create
方法,並提供 TransferConfig
資源的例項。
資料類型對應
下表將 PostgreSQL 資料類型對應至對應的 BigQuery 資料類型。
PostgreSQL 資料類型 | BigQuery 資料類型 |
---|---|
bigint | INTEGER |
bigserial | INTEGER |
bit(n) | STRING |
bit varying(n) | STRING |
boolean | BOOLEAN |
bytea | BYTES |
character | STRING |
character varying | STRING |
double precision | FLOAT |
integer | INTEGER |
numeric(precision, scale)/decimal(precision, scale) | NUMERIC |
real | FLOAT |
smallint | INTEGER |
smallserial | INTEGER |
serial | INTEGER |
text | INTEGER |
date | DATE |
time [ (p) ] [ without timezone ] | TIMESTAMP |
time [ (p) ] with time zone | TIMESTAMP |
timestamp [ (p) ] [ without timezone ] | TIMESTAMP |
timestamp [ (p) ] with time zone | TIMESPAMP |
xml | STRING |
tsquery | STRING |
tsvector | STRING |
uuid | STRING |
box | STRING |
cidr | STRING |
circle | STRING |
inet | STRING |
interval | STRING |
json | STRING |
jsonb | STRING |
line | STRING |
lseg | STRING |
macaddr | STRING |
macaddr8 | STRING |
money | STRING |
path | STRING |
point | STRING |
polygon | STRING |
疑難排解
如果您無法順利設定資料移轉作業,請參閱PostgreSQL 移轉問題。
後續步驟
- 如需 BigQuery 資料移轉服務的總覽,請參閱「什麼是 BigQuery 資料移轉服務?」。
- 如要瞭解如何使用移轉作業,包括取得移轉設定的相關資訊、列出移轉設定以及查看移轉作業執行記錄,請參閱「管理移轉作業」一文。
- 瞭解如何透過跨雲端作業載入資料。