通過創建AnalyticDB for MySQL 2.0數據源能夠實現Dataphin向AnalyticDB for MySQL 2.0寫入數據。本文為您介紹如何創建AnalyticDB for MySQL 2.0數據源。
前提條件
若您需在Dataphin中創建基于阿里云產品的數據源,在創建數據源前,需確保Dataphin的IP已添加至數據庫白名單(或安全組)中,使數據源與Dataphin網絡互通。具體操作,請參見數據源白名單配置。
背景信息
AnalyticDB for MySQL即阿里云的云原生數倉AnalyticDB for MySQL,是基于湖倉一體架構打造的實時數倉,高度兼容MySQL,支持毫秒級更新和亞秒級查詢。如果您使用的是云原生數倉AnalyticDB for MySQL,在對接Dataphin進行數據開發時,您需要先完成AnalyticDB for MySQL數據源的創建。更多云原生數倉AnalyticDB for MySQL信息,請參見云原生數據倉庫AnalyticDB for MySQL版-什么是云原生數據倉庫AnalyticDB for MySQL版。
權限說明
僅支持擁有新建數據源權限點的自定義全局角色和超級管理員、數據源管理員、板塊架構師、項目管理員系統角色創建數據源。
操作步驟
在Dataphin首頁,單擊頂部菜單欄管理中心 > 數據源管理。
在數據源頁面,單擊+新建數據源。
在新建數據源對話框的關系型數據庫區域,選擇AnalyticDB for MySQL 2.0。
如果您最近使用過AnalyticDB for MySQL2.0,也可以在最近使用區域選擇AnalyticDB for MySQL2.0。同時,您也可以在搜索框中,輸入AnalyticDB for MySQL2.0的關鍵詞,快速篩選。
在新建AnalyticDB for MySQL 2.0數據源對話框中,配置連接數據源參數。
配置數據源的基本信息。
參數
描述
數據源名稱
命名規則如下:
只能包含中文、英文字母大小寫、數字、下劃線(_)或短劃線(-)。
長度不能超過64字符。
數據源編碼
配置數據源編碼后,您可以在Flink_SQL任務中通過
數據源編碼.表名稱
或數據源編碼.schema.表名稱
的格式引用數據源中的表;如果需要根據所處環境自動訪問對應環境的數據源,請通過${數據源編碼}.table
或${數據源編碼}.schema.table
的變量格式訪問。更多信息,請參見Flink_SQL任務開發方式。重要目前僅支持MySQL、Hologres、MaxCompute數據源。
數據源編碼配置成功后不支持修改。
數據源描述
對數據源的簡單描述。不得超過128個字符。
數據源配置
選擇需要配置的數據源:
如果業務數據源區分生產數據源和開發數據源,則選擇生產+開發數據源。
如果業務數據源不區分生產數據源和開發數據源,則選擇生產數據源。
標簽
您可根據標簽給數據源進行分類打標,如何創建標簽,請參見管理數據源標簽。
配置數據源與Dataphin的連接參數。
若您的數據源配置選擇生產+開發數據源,則需配置生產+開發數據源的連接信息。如果您的數據源配置為生產數據源,僅需配置生產數據源的連接信息。
說明通常情況下,生產數據源和開發數據源需配置為非同一個數據源,以實現開發數據源與生產數據源的環境隔離,降低開發數據源對生產數據源的影響。但Dataphin也支持配置成同一個數據源,即相同參數值。
參數
描述
JDBC URL
鏈接地址的格式為
jdbc:mysql//host:port/dbname
。用戶名、密碼
數據庫的用戶名和賬號密碼。
訪問方式
僅支持公網IP訪問。
配置數據源的高級設置。
參數
描述
connectTimeout
數據庫的connectTimeout時長(單位:毫秒),默認900000毫秒(15分鐘)。
說明若您在JDBC URL中帶有connectTimeout配置,則connectTimeout為JDBC URL中配置的超時時間。
Dataphin V3.11版本之前的創建數據源,connectTimeout默認為
-1
,表示無超時限制。
socketTimeout
數據庫的socketTimeout時長(單位:毫秒)默認1800000毫秒(30分鐘)。
說明若您在JDBC URL中帶有socketTimeout配置,則socketTimeout為JDBC URL中配置的超時時間。
Dataphin V3.11版本之前的創建數據源,socketTimeout默認為
-1
,表示無超時限制。
單擊測試連接,測試數據源是否可以和Dataphin進行正常的連通。
重要如果連接測試失敗,您可以根據網絡連通常見問題進行排查。詳細內容,請參見網絡連通解決方案。
測試成功后,單擊確定,完成AnalyticDB for MySQL2.0數據源的創建。