Trước hết, vui lòng xóa các phần cấu hình HDFS và CKAN. Bạn sẽ tránh được các bản ghi không cần thiết liên quan đến các thành phần đó khi chạy Cygnus. Tất nhiên, hãy nhớ xóa tất cả các tham chiếu đến bồn rửa và kênh; cụ thể:
cygnusagent.sources = http-source
cygnusagent.sinks = mysql-sink
cygnusagent.channels = mysql-channel
...
cygnusagent.sources.http-source.channels = mysql-channel
Thứ hai, câu trả lời cho câu hỏi của bạn có thể được tìm thấy trong tài liệu:
Trong các bảng, chúng tôi có thể tìm thấy hai tùy chọn:
- Đã sửa các hàng 8 trường, như thường lệ:recvTimeTs, recvTime, entityId, entityType, attrName, attrType, attrValue và attrMd. Các bảng này (và cơ sở dữ liệu) được tạo tại thời điểm thực thi nếu bảng không tồn tại trước đó để chèn hàng. Về attrValue, ở dạng đơn giản nhất, giá trị này chỉ là một chuỗi, nhưng kể từ Orion 0.11.0, nó có thể là đối tượng Json hoặc mảng Json. Về attrMd, nó chứa một chuỗi tuần tự hóa mảng siêu dữ liệu cho thuộc tính trong Json (nếu thuộc tính không có siêu dữ liệu, một mảng trống [] sẽ được chèn vào),
- Hai cột cho mỗi thuộc tính của thực thể (một cho giá trị và một cho siêu dữ liệu), cộng với một cột bổ sung về thời gian nhận dữ liệu (recv_time). Loại bảng này (và cơ sở dữ liệu) phải được cung cấp trước đó để thực thi Cygnus vì mỗi thực thể có thể có số lượng thuộc tính khác nhau và các thông báo phải đảm bảo một giá trị cho mỗi thuộc tính được thông báo.
Hành vi của trình kết nối liên quan đến đại diện bên trong của dữ liệu được điều chỉnh thông qua tham số cấu hình, attr_persistence, có giá trị có thể là hàng hoặc cột.
Có thể có vấn đề với việc ghi, tôi nghĩ đoạn cuối cùng phải kết thúc là "... toàn bộ giá trị có thể là hàng hoặc cột, và có hành vi tương ứng với các tùy chọn được mô tả ở trên " .
I E. nếu bạn đang sử dụng chế độ cột, thì cơ sở dữ liệu và các bảng phải được cung cấp nâng cao.
Có một câu hỏi tương tự nơi tôi giải thích chi tiết hơn về một hành vi như vậy.
HTH!
