Pertama-tama, jangan ragu untuk menghapus bagian konfigurasi HDFS dan CKAN. Anda akan menghindari log yang tidak perlu terkait dengan komponen tersebut saat menjalankan Cygnus. Tentu saja, ingatlah untuk menghapus semua referensi ke sink dan saluran; khusus:
cygnusagent.sources = http-source
cygnusagent.sinks = mysql-sink
cygnusagent.channels = mysql-channel
...
cygnusagent.sources.http-source.channels = mysql-channel
Kedua, jawaban atas pertanyaan Anda dapat ditemukan di dokumentasi:
Dalam tabel, kita dapat menemukan dua pilihan:
- Memperbaiki baris 8 bidang, seperti biasa:recvTimeTs, recvTime, entityId, entityType, attrName, attrType, attrValue, dan attrMd. Tabel ini (dan database) dibuat pada waktu eksekusi jika tabel tidak ada sebelumnya untuk penyisipan baris. Mengenai attrValue, dalam bentuknya yang paling sederhana, nilai ini hanyalah sebuah string, tetapi karena Orion 0.11.0 itu bisa berupa objek Json atau array Json. Mengenai attrMd, ini berisi serialisasi string dari larik metadata untuk atribut di Json (jika atribut tidak memiliki metadata, larik kosong [] dimasukkan),
- Dua kolom untuk setiap atribut entitas (satu untuk nilai dan lainnya untuk metadata), ditambah kolom tambahan tentang waktu penerimaan data (recv_time). Tabel semacam ini (dan database) harus disediakan sebelumnya untuk eksekusi Cygnus , karena setiap entitas mungkin memiliki jumlah atribut yang berbeda, dan pemberitahuan harus memastikan nilai per setiap atribut diberitahukan.
Perilaku konektor mengenai representasi internal data diatur melalui parameter konfigurasi, attr_persistence, yang nilainya dapat berupa baris atau kolom.
Mungkin ada masalah dengan penulisan, saya pikir paragraf terakhir harus diakhiri sebagai "... nilai keseluruhan dapat berupa baris atau kolom, dan yang perilakunya sesuai dengan opsi yang dijelaskan di atas, masing-masing " .
Yaitu. jika Anda menggunakan mode kolom, maka database dan tabel harus disediakan di tingkat lanjut.
Ada pertanyaan serupa di mana saya menjelaskan secara lebih rinci perilaku seperti itu.
HTH!
