DataLakeAnalytics中如何讀寫PolarDB的數(shù)據(jù)

Data Lake Analytics中如何讀寫PolarDB的數(shù)據(jù)，很多新手對(duì)此不是很清楚，為了幫助大家解決這個(gè)難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來學(xué)習(xí)下，希望你能有所收獲。

專注于為中小企業(yè)提供成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站制作服務(wù),電腦端+手機(jī)端+微信端的三站合一,更高效的管理,為中小企業(yè)襄城免費(fèi)做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動(dòng)了上1000家企業(yè)的穩(wěn)健成長(zhǎng)，幫助中小企業(yè)通過網(wǎng)站建設(shè)實(shí)現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。

Data Lake Analytics 作為云上數(shù)據(jù)處理的樞紐，最近加入了對(duì)于PolarDB的支持, PolarDB 是阿里云自研的下一代關(guān)系型分布式云原生數(shù)據(jù)庫(kù)，100%兼容MySQL，存儲(chǔ)容量最高可達(dá) 100T，性能最高提升至 MySQL 的 6 倍。這篇教程帶你玩轉(zhuǎn) DLA 的 PolarDB 支持。

創(chuàng)建數(shù)據(jù)庫(kù)

在 DLA 里面創(chuàng)建一個(gè)底層映射到 PolarDB 的外表的語(yǔ)法如下:

CREATE SCHEMA porlardb_test WITH DBPROPERTIES (
  CATALOG = 'mysql', 
  LOCATION = 'jdbc:mysql://pc-bp1dlebalabala.rwlb.rds.aliyuncs.com:3306/dla_test',
  USER = 'dla_test_1',
  PASSWORD = 'the-fake-password',
  VPC_ID = 'vpc-2zeij924vxd303kwifake',
  INSTANCE_ID = 'rm-2zer0vg58mfo5fake'
);

跟普通的建表不同的是這里多了兩個(gè)屬性: VPC_ID 和 INSTANCE_ID 。VPC_ID 是你的PolarDB所在VPC的ID。

建表需要這兩個(gè)額外信息是因?yàn)楝F(xiàn)在用戶的數(shù)據(jù)庫(kù)都是處于用戶自己的VPC內(nèi)部，默認(rèn)情況下 DLA 是訪問不了用戶 VPC 里面的資源的，為了讓DLA能夠訪問到用戶PolarDB面的數(shù)據(jù)，我們需要利用阿里云的VPC反向訪問技術(shù)。

權(quán)限聲明: 當(dāng)您通過上述方式建庫(kù)，就視為您同意我們利用VPC反向訪問的技術(shù)去讀寫您的PolarDB。

另外您還需要把 100.104.0.0/16 IP地址段加入到你的PolarDB的白名單列表，這是我們VPC反向訪問的IP地段，如下圖:

cdn.com/7749f8bb0c3ef32d6d191a218f556c66c9ad8d0f.png">

同時(shí)細(xì)心的讀者可能注意到我們這里的 CATALOG 寫的是 mysql, 而不是 polardb, 這是因?yàn)?PolarDB 100%兼容MySQL，我們直接以MySQL協(xié)議去訪問就好了。

創(chuàng)建表

數(shù)據(jù)庫(kù)建完之后，我們可以建表了，我們先在你的 PolarDB 里面建立如下的 person 表用來做測(cè)試:

create table person (
       id int,
       name varchar(1023),
       age int
);

并且向里面插入一下測(cè)試數(shù)據(jù):

insert into person 
  values (1, 'james', 10), 
         (2, 'bond', 20), 
         (3, 'jack', 30), 
         (4, 'lucy', 40);

然后就可以在 DLA 的數(shù)據(jù)庫(kù)里面建立相應(yīng)的映射表了:

create external table person (
       id int,
       name varchar(1023),
       age int
);

這樣我們通過MySQL客戶端連接到 DLA 數(shù)據(jù)庫(kù)上面，就可以對(duì) PolarDB 數(shù)據(jù)庫(kù)里面的數(shù)據(jù)進(jìn)行查詢了:

mysql> select * from person;
+------+-------+------+
| id   | name  | age  |
+------+-------+------+
|    1 | james |   10 |
|    2 | bond  |   20 |
|    3 | jack  |   30 |
|    4 | lucy  |   40 |
+------+-------+------+
4 rows in set (0.35 sec)

看完上述內(nèi)容是否對(duì)您有幫助呢？如果還想對(duì)相關(guān)知識(shí)有進(jìn)一步的了解或閱讀更多相關(guān)文章，請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝您對(duì)創(chuàng)新互聯(lián)的支持。

文章名稱：DataLakeAnalytics中如何讀寫PolarDB的數(shù)據(jù)
文章源于：http://muchs.cn/article48/ijooep.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供軟件開發(fā)、手機(jī)網(wǎng)站建設(shè)、外貿(mào)網(wǎng)站建設(shè)、云服務(wù)器、網(wǎng)站收錄、建站公司

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)