673      人物

快速指引__DataHub實時數據通道_大數據計算服務-阿裏雲

本節主要描述使用DataHub Java SDK進行數據的讀寫。

準備工作

• 使用DataHub服務之前,需要注冊阿裏雲雲賬號,利用阿裏雲賬號的AccessId與AccessKey接入DataHub服務。

創建Project/Topic

• 登錄DataHub Web Console頁麵，創建Topic。

發布數據/訂閱數據

發布/訂閱數據需要使用SDK完成， DataHub Java SDK使用說明

// 新建client
Account account = new AliyunAccount("your access id", "your access key");
DatahubConfiguration conf = new DatahubConfiguration(account, "datahub endpoint");
DatahubClient client = new DatahubClient(conf);
String shardId = "0";
// 構造需要上傳的records
RecordSchema schema = client.getTopic("test_project", "test_topic").getRecordSchema();
List<RecordEntry> recordEntries = new ArrayList<~>();
RecordEntry entry = new RecordEntry(schema);
for (int i=0; i<entry.getFieldCount(); i++) {
    entry.setBigint(i, 1); //set your fields' value according to the field's type
}
entry.setShardId(shardId);
recordEntries.add(entry);
// 數據寫入
client.putRecords("test_project", "test_topic", recordEntries);
// 數據讀取
GetCursorResult cursor = client.getCursor("test_project", "test_topic", shardId, 1455869335000 /*ms*/);
GetRecordsResult r = client.getRecords("test_project", "test_topic", shardId, cursor.getCursor(), 10);