Sumber data Maxgraph - DataWorks

DataWorks Data Integration menyediakan Maxgraph Writer untuk menulis data dari tabel MaxCompute ke Maxgraph. Topik ini menjelaskan kemampuan sinkronisasi data ke sumber data Maxgraph.

Batasan

Anda hanya dapat menggunakan editor kode untuk mengonfigurasi node sinkronisasi batch guna menulis data ke sumber data Maxgraph.
Skenario penggunaan mencakup sinkronisasi data dari MaxCompute ke Maxgraph.

Siapkan akun Maxgraph yang memiliki izin yang diperlukan sebelum sinkronisasi data

Untuk menggunakan Maxgraph Writer dalam menulis data dari tabel MaxCompute ke Maxgraph, pastikan akun pembuatan Maxgraph memiliki izin baca pada tabel MaxCompute di Proyek MaxCompute Anda. Hubungi administrator Maxgraph untuk mendapatkan akun tersebut.

Mengembangkan node sinkronisasi data

Untuk detail lebih lanjut tentang prosedur konfigurasi, lihat Konfigurasikan Tugas Sinkronisasi Batch Menggunakan Editor Kode.
Untuk informasi tentang semua parameter yang dikonfigurasi dan kode yang dijalankan saat menggunakan editor kode untuk mengonfigurasi node sinkronisasi batch, lihat Lampiran: Kode dan Parameter.

Lampiran: Kode dan parameter

Lampiran: Konfigurasikan node sinkronisasi batch menggunakan editor kode

Kode untuk Maxgraph Writer

Kode berikut mengonfigurasi node sinkronisasi untuk menulis data simpul dan tepi ke Maxgraph.

Konfigurasikan node sinkronisasi untuk menulis data simpul ke Maxgraph

{
  "job": {
    "setting": {
      "speed": {
        "channel": 1 // Atur saluran menjadi 1. 
      },
      "errorLimit": {
        "record": 1000
      }
    },
    "content": [
      {
        "reader": {
          "name": "odpsreader",
          "parameter": {
            "accessId": "*****",
            "accessKey": "*****",
            "project": "maxgraph_dev",
            "table": "maxgraph_demo_person",
            "column": [ // Nama kolom dalam tabel MaxCompute. Nilai parameter ini memiliki pemetaan satu-satu dengan nilai parameter kolom Maxgraph Writer. 
              "id",
              "name",
              "age"
            ],
            "packageAuthorizedProject": "biggraph_dev",
            "splitMode": "record",
            "odpsServer": "******"
          }
        },
        "writer": {
          "name": "maxgraphwriter",
          "parameter": {
            "endpoint": "http://graph.alibaba.net",
            "graphName": "xxx",
            "accessId": "xxx",
            "accessKey": "xxx",
            "label": "person",
            "labelType": "vertex",
            "onlineMode": "partition",
            "splitSize": "256",
            "column": [ // Nama properti simpul dalam Maxgraph. Nilai parameter ini memiliki pemetaan satu-satu dengan nilai parameter kolom MaxCompute Reader. 
              "id",
              "name",
              "age"
            ]
          }
        }
      }
    ]
  }
}

Konfigurasikan node sinkronisasi untuk menulis data tepi ke Maxgraph

{
  "job": {
    "setting": {
      "speed": {
        "channel": 1 // Atur saluran menjadi 1. 
      },
      "errorLimit": {
        "record": 1000
      }
    },
    "content": [
      {
        "reader": {
          "name": "odpsreader",
          "parameter": {
            "accessId": "*****",
            "accessKey": "*****",
            "project": "maxgraph_dev",
            "table": "maxgraph_demo_knows",
            "column": [
              "person_id",
              "person_id2",
              "weight",
              "id"
            ],
            "packageAuthorizedProject": "biggraph_dev",
            "splitMode": "record",
            "odpsServer": "****"
          }
        },
        "writer": {
          "name": "maxgraphwriter",
          "parameter": {
            "endpoint": "http://graph.alibaba.net",
            "graphName": "xxx",
            "accessId": "xxx",
            "accessKey": "xxx",
            "label": "knows",
            "labelType": "edge",
            "srcLabel": "person",
            "dstLabel": "person",
            "onlineMode": "partition",
            "splitSize": "256",
            "column": [ 
              {
                "name": "id", // Nama properti dalam Maxgraph. 
                "propertyType": "srcPrimaryKey" // Tipe properti. Nilai valid: srcPrimaryKey, dstPrimaryKey, dan edgeProperty. 
              },
              {
                "name": "id",
                "propertyType": "dstPrimaryKey"
              },
              {
                "name": "weight",
                "propertyType": "edgeProperty"
              },
              {
                "name": "id",
                "propertyType": "edgeProperty"
              }
            ]
          }
        }
      }
    ]
  }
}

Parameter dalam kode untuk Maxgraph Writer

Parameter	Deskripsi	Diperlukan	Nilai default
endpoint	Titik akhir Maxgraph.	Ya	Tidak ada nilai default
graphName	Nama instance Maxgraph.	Ya	Tidak ada nilai default
accessId	Nama pengguna.	Ya	Tidak ada nilai default
accessKey	Kata sandi.	Ya	Tidak ada nilai default
label	Label, yaitu nama simpul atau tepi.	Ya	Tidak ada nilai default
labelType	Jenis label. Nilai valid: vertex dan edge.	Ya	Tidak ada nilai default
srcLabel	Label simpul awal dalam tepi. Parameter ini berlaku hanya saat Anda mengimpor data tentang tepi.	Ya	Tidak ada nilai default
dstLabel	Label simpul akhir dalam tepi. Parameter ini berlaku hanya saat Anda mengimpor data tentang tepi.	Ya	Tidak ada nilai default
splitSize	Ukuran shard dalam pekerjaan MapReduce. Satuan: MB.	Tidak	256MB
onlineMode	Mode di mana data diunggah ke penyimpanan Maxgraph. Nilai valid: partition: Saat data sedang diunggah, baik catatan data yang ada maupun catatan data baru yang diunggah mungkin dapat di-query. Namun, konsistensi data dijamin. Kecepatan unggah data dalam mode ini lebih cepat daripada mode type. type: Saat data sedang diunggah, hanya catatan data yang ada yang dapat di-query. Catatan data baru dapat di-query setelah data diunggah. Kecepatan unggah data dalam mode ini lebih lambat daripada mode partition.	Tidak	type
column	Nama properti simpul. Parameter ini berlaku hanya saat Anda mengimpor data tentang simpul.	Ya	Tidak ada nilai default
name	Nama properti.	Diperlukan hanya saat Anda mengimpor data tentang tepi	Tidak ada nilai default
propertyType	Jenis properti. Nilai valid: srcPrimaryKey, dstPrimaryKey, dan edgeProperty.	Diperlukan hanya saat Anda mengimpor data tentang tepi	Tidak ada nilai default
srcPrimaryKey	Kunci utama simpul awal. Parameter ini berlaku hanya saat Anda mengimpor data tentang tepi.	Diperlukan hanya saat Anda mengimpor data tentang tepi	Tidak ada nilai default
dstPrimaryKey	Kunci utama simpul akhir. Parameter ini berlaku hanya saat Anda mengimpor data tentang tepi.	Diperlukan hanya saat Anda mengimpor data tentang tepi	Tidak ada nilai default
edgeProperty	Properti tepi. Parameter ini dapat dibiarkan kosong jika tepi tidak memiliki properti.	Tidak	Tidak ada nilai default