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);