創(chuàng)建PolarDB數(shù)據(jù)源
通過創(chuàng)建PolarDB數(shù)據(jù)源能夠?qū)崿F(xiàn)Dataphin讀取PolarDB的業(yè)務(wù)數(shù)據(jù)或向PolarDB寫入數(shù)據(jù)。本文為您介紹如何創(chuàng)建PolarDB數(shù)據(jù)源。
前提條件
若您需在Dataphin中創(chuàng)建基于阿里云產(chǎn)品的數(shù)據(jù)源,創(chuàng)建數(shù)據(jù)源前,需確保Dataphin的IP已添加至數(shù)據(jù)庫白名單(或安全組)中,使數(shù)據(jù)源與Dataphin網(wǎng)絡(luò)互通。具體操作,請參見數(shù)據(jù)源白名單配置。
背景信息
PolarDB是阿里云自主研發(fā)新一代關(guān)系型數(shù)據(jù)庫,兼容MySQL、PostgreSQL語法的云托管數(shù)據(jù)庫產(chǎn)品。在計(jì)算存儲(chǔ)分離架構(gòu)下,利用了軟硬件結(jié)合的優(yōu)勢,為用戶提供具備極致彈性、高性能、海量存儲(chǔ)、安全可靠的數(shù)據(jù)庫服務(wù)。如果您使用的是PolarDB,在對接Dataphin進(jìn)行數(shù)據(jù)開發(fā)時(shí),您需要先完成PolarDB數(shù)據(jù)源的創(chuàng)建。更多PolarDB信息,請參見什么是PolarDB。
權(quán)限說明
僅支持具備新建數(shù)據(jù)源權(quán)限點(diǎn)的自定義全局角色和超級(jí)管理員、數(shù)據(jù)源管理員、板塊架構(gòu)師、項(xiàng)目管理員角色創(chuàng)建數(shù)據(jù)源。
操作步驟
在Dataphin首頁,單擊頂部菜單欄管理中心 > 數(shù)據(jù)源管理。
在數(shù)據(jù)源頁面,單擊+新建數(shù)據(jù)源。
在新建數(shù)據(jù)源對話框的關(guān)系型數(shù)據(jù)庫區(qū)域,選擇PolarDB。
如果您最近使用過PolarDB,也可以在最近使用區(qū)域選擇PolarDB。同時(shí),您也可以在搜索框中,輸入PolarDB的關(guān)鍵詞,快速篩選。
在新建PolarDB數(shù)據(jù)源對話框中,配置連接數(shù)據(jù)源參數(shù)。
配置數(shù)據(jù)源的基本信息。
參數(shù)
說明
數(shù)據(jù)源名稱
填寫數(shù)據(jù)源名稱。命名規(guī)則如下:
只能包含中文、英文字母大小寫、數(shù)字、下劃線(_)或短劃線(-)。
長度不能超過64個(gè)字符。
數(shù)據(jù)源編碼
配置數(shù)據(jù)源編碼后,您可以在Flink_SQL任務(wù)或使用Dataphin JDBC客戶端中,通過
數(shù)據(jù)源編碼.表名稱
或數(shù)據(jù)源編碼.schema.表名稱
的格式直接訪問Dataphin數(shù)據(jù)源表,實(shí)現(xiàn)快捷消費(fèi);如果需要根據(jù)任務(wù)執(zhí)行環(huán)境自動(dòng)切換數(shù)據(jù)源,請通過${數(shù)據(jù)源編碼}.table
或${數(shù)據(jù)源編碼}.schema.table
的變量格式訪問。更多信息,請參見Flink_SQL任務(wù)開發(fā)方式。重要數(shù)據(jù)源編碼配置成功后不支持修改。
數(shù)據(jù)源描述
對PolarDB數(shù)據(jù)源的簡單描述。不得超過128個(gè)字符。
數(shù)據(jù)庫類型
基于PolarDB底層的引擎類型,選擇對應(yīng)的數(shù)據(jù)庫類型:
如果PolarDB底層的引擎為MySQL,則選擇MYSQL。
如果PolarDB底層的引擎為PostgreSQL,則選擇POSTGRE_SQL。
數(shù)據(jù)源配置
基于業(yè)務(wù)數(shù)據(jù)源是否區(qū)分生產(chǎn)數(shù)據(jù)源和開發(fā)數(shù)據(jù)源:
如果業(yè)務(wù)數(shù)據(jù)源區(qū)分生產(chǎn)數(shù)據(jù)源和開發(fā)數(shù)據(jù)源,則選擇生產(chǎn)+開發(fā)數(shù)據(jù)源。
如果業(yè)務(wù)數(shù)據(jù)源不區(qū)分生產(chǎn)數(shù)據(jù)源和開發(fā)數(shù)據(jù)源,則選擇生產(chǎn)數(shù)據(jù)源。
標(biāo)簽
您可根據(jù)標(biāo)簽對數(shù)據(jù)源進(jìn)行分類打標(biāo),如何創(chuàng)建標(biāo)簽,請參見管理數(shù)據(jù)源標(biāo)簽。
配置數(shù)據(jù)源與Dataphin的連接參數(shù)。
若您的數(shù)據(jù)源配置選擇生產(chǎn)+開發(fā)數(shù)據(jù)源,則需配置生產(chǎn)+開發(fā)數(shù)據(jù)源的連接信息。如果您的數(shù)據(jù)源配置為生產(chǎn)數(shù)據(jù)源,僅需配置生產(chǎn)數(shù)據(jù)源的連接信息。
說明通常情況下,生產(chǎn)數(shù)據(jù)源和開發(fā)數(shù)據(jù)源需配置為非同一個(gè)數(shù)據(jù)源,以實(shí)現(xiàn)開發(fā)數(shù)據(jù)源與生產(chǎn)數(shù)據(jù)源的環(huán)境隔離,降低開發(fā)數(shù)據(jù)源對生產(chǎn)數(shù)據(jù)源的影響。但Dataphin也支持配置成同一個(gè)數(shù)據(jù)源,即相同參數(shù)值。
參數(shù)
說明
JDBC URL
請根據(jù)所選的數(shù)據(jù)庫類型配置對應(yīng)鏈接地址。
MySQL:格式為:
jdbc:mysql://host:port/dbname
PostgreSQL:格式為:
jdbc:postgresql://host:port/dbname
Schema
當(dāng)上述步驟中數(shù)據(jù)庫類型選擇為PostgreSQL,需配置Schema。Schema即PostgreSQL實(shí)例的數(shù)據(jù)庫名稱。
用戶名、密碼
登錄PolarDB數(shù)據(jù)源引擎MySQL或PostgreSQL的用戶名和密碼。
類型
支持公網(wǎng)數(shù)據(jù)庫、阿里云數(shù)據(jù)庫與ECS(VPC)自建數(shù)據(jù)庫,您可根據(jù)您數(shù)據(jù)庫類型及業(yè)務(wù)情況進(jìn)行選擇與配置:
公網(wǎng)數(shù)據(jù)庫:通過公網(wǎng)直接訪問的數(shù)據(jù)庫。
阿里云數(shù)據(jù)庫:在阿里云購買的數(shù)據(jù)庫。支持VPC網(wǎng)絡(luò)或公網(wǎng)IP進(jìn)行訪問。VPC網(wǎng)絡(luò)訪問數(shù)據(jù)庫需配置以下信息:
區(qū)域:數(shù)據(jù)庫所在Region。僅支持Dataphin實(shí)例相同區(qū)域的數(shù)據(jù)庫。如您的Dataphin實(shí)例位于華東2(上海),僅支持選擇華東2(上海)區(qū)域。
VPC ID:填寫數(shù)據(jù)庫所在VPC網(wǎng)絡(luò)的VPC ID。您可登錄專有網(wǎng)絡(luò)控制臺(tái)進(jìn)行查看。如下圖所示:
VPC實(shí)例ID:填寫數(shù)據(jù)庫的專有網(wǎng)絡(luò)實(shí)例ID,即
VpcCloudInstanceId
。您可以通過調(diào)用DescribeDrdsInstance API進(jìn)行獲取。更多信息,請參見DescribeDrdsInstance。
ECS(VPC)自建數(shù)據(jù)庫:您在阿里云ECS上自建的數(shù)據(jù)庫。支持VPC方式訪問。VPC網(wǎng)絡(luò)訪問數(shù)據(jù)庫需配置以下信息:
區(qū)域:據(jù)庫所在Region。僅支持Dataphin實(shí)例相同區(qū)域的數(shù)據(jù)庫。如您的Dataphin實(shí)例位于華東2(上海),僅支持選擇華東2(上海)區(qū)域。
VPC ID:填寫ECS所在VPC網(wǎng)絡(luò)的VPC ID。您可登錄專有網(wǎng)絡(luò)控制臺(tái)進(jìn)行查看。如下圖所示:
ECS ID:填寫部署數(shù)據(jù)庫的ECS服務(wù)器的ECS ID。您可登錄ECS控制臺(tái)進(jìn)行查看。如下圖所示:
配置數(shù)據(jù)源的高級(jí)設(shè)置。
參數(shù)
說明
connectTimeout
數(shù)據(jù)庫的connectTimeout時(shí)長(單位:毫秒),默認(rèn)900000毫秒(15分鐘)。
說明若您在JDBC URL中帶有connectTimeout配置,則connectTimeout為JDBC URL中配置的超時(shí)時(shí)間。
Dataphin V3.11版本之前的創(chuàng)建數(shù)據(jù)源,connectTimeout默認(rèn)為
-1
,表示無超時(shí)限制。
socketTimeout
數(shù)據(jù)庫的socketTimeout時(shí)長(單位:毫秒),默認(rèn)1800000毫秒(30分鐘)。
說明若您在JDBC URL中帶有socketTimeout配置,則socketTimeout為JDBC URL中配置的超時(shí)時(shí)間。
Dataphin V3.11版本之前的創(chuàng)建數(shù)據(jù)源,socketTimeout默認(rèn)為
-1
,表示無超時(shí)限制。
連接重試次數(shù)
數(shù)據(jù)庫連接超時(shí),將自動(dòng)重試連接直到完成設(shè)定的重試次數(shù)。若達(dá)最大重試次數(shù)仍未連接成功,則連接失敗。
說明默認(rèn)重試次數(shù)為1次,支持配置0~10之間參數(shù)。
連接重試次數(shù)將默認(rèn)應(yīng)用于離線集成任務(wù)與全域質(zhì)量(需開通資產(chǎn)質(zhì)量功能模塊),離線集成任務(wù)中支持單獨(dú)配置任務(wù)級(jí)別的重試次數(shù)。
單擊測試連接,測試數(shù)據(jù)源是否可以和Dataphin進(jìn)行正常的連通。
重要如果連接測試失敗,您可以根據(jù)網(wǎng)絡(luò)連通常見問題進(jìn)行排查。詳細(xì)內(nèi)容,請參見網(wǎng)絡(luò)連通解決方案。
測試成功后,單擊確定,完成PolarDB數(shù)據(jù)源的創(chuàng)建。