Aliyun Datahub NodeJS SDK
阿里云 Datahub Restful API 的 NodeJS 封装
官网没有提供 NodeJS 版本的 SDK, 所以基于 Restful 接口文档自己封装了一下, 方便开发使用.
项目尚在开发中...
Usage
yarn add aliyun-datahub-sdk-node
const Datahub = ;const RecordType FieldType DatahubOptions Field RecordSchema TupleRecord BlobRecord CursorType } = Datahub; // 创建 Datahub Clientconst datahubOption = "https://dh-cn-shanghai.aliyuncs.com" processenvACCESS_KEY_ID processenvACCESS_KEY_SECRET;const dh = datahubOption; // 创建 Projectdh // 创建 Topicconst testRecordSchema = //[ name, type, notnull ] 'field_string' FieldTypeSTRING true 'field_integer' FieldTypeINTEGER false 'field_boolean' FieldTypeBOOLEAN true 'field_timestamp' FieldTypeTIMESTAMP truedh) dh) // 推送数据let testData = field_string: 'abc' field_integer: 1 field_boolean: false field_timestamp: let testTupleRecords = testTupleRecordsawait dh) let testBlobRecords = 'test'await dh) // 拉取数据(从头开始)let _schema = await dhdataRecordSchemalet _cursor = await dhdataCursorlet res = await dh_cursor = resdataNextCursorlet records = resdataRecords// ...更新 cursor 以循环获取数据 // 如果是 blob 类型, schema 参数设置为空dh
Test
yarn test