AnalyticDB for MySQL 2.0 veri kaynağı, DataWorks içinde AnalyticDB for MySQL 2.0 ile diğer veri sistemleri arasında çift yönlü veri senkronizasyonu sağlar. Çevrimdışı bir senkronizasyon görevinin parçası olarak AnalyticDB for MySQL 2.0'dan veri okumak veya bu sisteme veri yazmak için kullanın.
Sınırlamalar
Çevrimdışı senkronizasyon, görünümlerden veri okumayı destekler.
AnalyticDB for MySQL 2.0 Reader, çoklu değer türlerini desteklemez. Kaynak veriler çoklu değer türleri içeriyorsa senkronizasyon görevi başarısız olur.
Desteklenen alan türleri
Çevrimdışı okuma
Aşağıdaki tabloda AnalyticDB for MySQL 2.0 Reader için veri türü eşlemeleri listelenmiştir. Veriler, AnalyticDB for MySQL 2.0'dan DataX üzerinden MaxCompute'e akar.
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Çevrimdışı yazma
Aşağıdaki tabloda AnalyticDB for MySQL 2.0 Writer için veri türü eşlemeleri listelenmiştir.
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Veri kaynağı ekleme
DataWorks'te bir senkronizasyon görevi geliştirmeden önce, gerekli veri kaynağını Veri kaynağı yönetimi bölümündeki talimatları izleyerek ekleyin. Bir veri kaynağı eklerken parametre açıklamaları DataWorks konsolunda mevcuttur.
Veri senkronizasyon görevi geliştirme
Tek bir tablo için çevrimdışı senkronizasyon görevini yapılandırma
Görevi yapılandırmak için aşağıdaki yöntemlerden birini kullanın:
Kodsuz UI: Bkz. Kodsuz UI'da görev yapılandırma.
Kod düzenleyici: Bkz. Kod düzenleyicide görev yapılandırma. Tam parametre referansı ve komut dosyası örnekleri için bkz. Ek: Komut dosyası örnekleri ve parametre açıklamaları.
Tüm veritabanı için çevrimdışı okuma senkronizasyon görevini yapılandırma
Ek: Komut dosyası örnekleri ve parametre açıklamaları
Reader
Komut dosyası örneği
{
"type": "job",
"version": "2.0",
"steps": [
{
"stepType": "ads",
"parameter": {
"datasource": "ads_demo",
"table": "th_test",
"column": [
"id",
"testtinyint",
"testbigint",
"testdate",
"testtime",
"testtimestamp",
"testvarchar",
"testdouble",
"testfloat"
],
"mode": "ODPS",
"odps": {
"accessId": "<yourAccessKeyId>",
"accessKey": "<yourAccessKeySecret>",
"account": "<yourAccount>",
"odpsServer": "http://service.cn-shanghai-vpc.maxcompute.aliyun-inc.com/api",
"tunnelServer": "http://dt.cn-shanghai-vpc.maxcompute.aliyun-inc.com",
"accountType": "aliyun",
"project": "odps_test"
}
},
"name": "Reader",
"category": "reader"
},
{
"stepType": "stream",
"parameter": {},
"name": "Writer",
"category": "writer"
}
],
"order": {
"hops": [
{
"from": "Reader",
"to": "Writer"
}
]
},
"setting": {
"errorLimit": {
"record": ""
},
"speed": {
"concurrent": 2,
"throttle": true,
"mbps": "12"
}
}
}Reader parametreleri
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Dışa aktarma modu seçme
mode parametresi, Reader'ın AnalyticDB for MySQL 2.0'dan verileri nasıl dışa aktardığını kontrol eder.
|
|
|
|
|
|
|
|
|
|
|
|
Writer
Komut dosyası örneği
{
"type": "job",
"version": "2.0",
"steps": [
{
"stepType": "stream",
"parameter": {},
"name": "Reader",
"category": "reader"
},
{
"stepType": "ads",
"parameter": {
"datasource": "",
"table": "",
"partition": "",
"column": [
"id"
],
"writeMode": "insert",
"batchSize": "256",
"overWrite": "true",
"options.ignoreEmptySource": true
},
"name": "Writer",
"category": "writer"
}
],
"order": {
"hops": [
{
"from": "Reader",
"to": "Writer"
}
]
},
"setting": {
"errorLimit": {
"record": "0"
},
"speed": {
"throttle": true,
"concurrent": 1,
"mbps": "12"
}
}
}Writer parametreleri
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Yazma modu seçme
writeMode parametresi, Writer'ın verileri AnalyticDB for MySQL 2.0'a nasıl içe aktardığını kontrol eder.
|
|
|
|
|
|
|
|
|
|
|
|