› 推特 ›阿里云技术文档›正文

SDK多值写入_SDK多值示例_SDK 参考_时序数据库 TSDB_时序时空数据库TSDB

admin 阿里云技术文档 2020-02-11 200 0
阿里云服务器优惠

SDK多值写入

本文通过示例代码指导您使用多值模型写入数据

注意：多值模型仅在 0.2.0 版本及以上的 SDK 支持。关于最新 SDK 版本的说明及下载，请参见 SDK 版本说明。之前版本的 SDK 所支持的多值模型实际是模拟多值模型，不鼓励继续使用。之前通过 MultiValue 类写入的数据并不能通过最新的 SDK 多值模型相关类 (MultiField) 进行查询。

多值模型的数据写入

示例代码：

  1.         /*
  2.          *  通过 multiFieldPutSync() API。
  3.          *  该 API 支持单点和多点(List)写入。
  4.          *  
  5.          *  下面是必须写入时必须提供的信息:
  6.          *  Metric: 数据指标的类别。相当于 influxdb 的 Measurement。
  7.          *  Fields: 数据指标的度量信息（相当于指标下的子类别）。即一个 metric 支持多个 fields。如 metric 为 wind，该 metric 可以有多个 fields：direction, speed, direction, description 和 temperature。
  8.          *  Timestamp: 数据点的时间戳
  9.          *  Tags: 时间线额外的信息，如"型号=ABC123"、"出厂编号=1234567890"等。
  10.          */
  11.         MultiFieldPoint point1 = MultiFieldPoint.metric("wind").timestamp(1346846400L)
  12.                 .fields("speed", 20.0)
  13.                 .fields("level", 5)
  14.                 .fields("direction", "NE")
  15.                 .fields("description", "Breeze")
  16.                   .fields("temperature", "18.9")
  17.                 .tag("sensor", "IOTE_1988_0001")
  18.                   .tag("district", "Yuhang")
  19.                   .tag("city", "Hangzhou")
  20.                   .tag("province", "Zhejiang")
  21.                   .build();
  23.         // 同步写入
  24.         tsdb.multiFieldPutSync(multiValuedPoint);
  25.         // 同步写入并且获取写入成功失败总结
  26.         tsdb.multiFieldPutSync(multiValuedPoint, SummaryResult.class);
  27.         // 同步写入并且获取详细的写入成功或者失败信息
  28.         tsdb.multiFieldPutSync(multiValuedPoint, DetailsResult.class);

多值模型的异步写入

注意：多值模型异步仅在 0.2.1 版本及以上的 SDK 支持。关于最新 SDK 版本的说明及下载，请参见 SDK 版本说明。

不使用回调方法

默认的TSDBConfig没有设置多值异步写入回调方法。示例代码：

  1. TSDBConfig config = TSDBConfig.address("127.0.0.1", 8242)
  2.                 // 批次写入时每次提交数据量
  3.                 .batchPutSize(500)
  4.                 // 单值异步写入线程数
  5.                 .batchPutConsumerThreadCount(1)
  6.                 // 多值异步写入缓存队列长度
  7.                 .multiFieldBatchPutBufferSize(10000)
  8.                 // 多值异步写入线程数
  9.                 .multiFieldBatchPutConsumerThreadCount(1)
  10.                 .config();
  12.         // 特别注意，TSDB只需初始化一次即可
  13.         TSDB tsdb = TSDBClientFactory.connect(config);
  15.         MultiFieldPoint point = MultiFieldPoint
  16.                 .metric("test-test-test")
  17.                 .tag("a", "1")
  18.                 .tag("b", "2")
  19.                 .timestamp(System.currentTimeMillis())
  20.                 .field("f1", Math.random())
  21.                 .field("f2", Math.random())
  22.                 .build();
  23.         tsdb.multiFieldPut(point);
  25.         // 特别注意，在应用生命周期内不用关闭TSDB实例，直到应用结束时关闭即可
  26.         tsdb.close();
  27.     }

使用普通回调方法

普通回调方法仅报告当写入成功时的数据点列表，或者当写入失败时的数据点列表以及对应的写入异常。

示例代码：

  1.       // 创建一个普通回调方法，用于处理写入成功或者失败后的情况
  2.       AbstractMultiFieldBatchPutCallback callback = new MultiFieldBatchPutCallback() {
  4.             @Override
  5.             public void response(String address, List<MultiFieldPoint> points, Result result) {
  6.                 int count = num.addAndGet(points.size());
  7.                 System.out.println(result);
  8.                 System.out.println("已处理" + count + "个点");
  9.             }
  10.             final AtomicInteger num = new AtomicInteger();
  11.             @Override
  12.             public void failed(String address, List<MultiFieldPoint> points, Exception ex) {
  13.                 System.err.println("业务回调出错！" + points.size() + " error!");
  14.                 ex.printStackTrace();
  15.             }
  16.         };
  18.        TSDBConfig config = TSDBConfig.address("127.0.0.1", 8242)
  19.                 .httpConnectTimeout(90)
  20.                 // 批次写入时每次提交数据量
  21.                 .batchPutSize(500)
  22.                 // 单值异步写入线程数
  23.                 .batchPutConsumerThreadCount(1)
  24.                 // 多值异步写入缓存队列长度
  25.                 .multiFieldBatchPutBufferSize(10000)
  26.                 // 多值异步写入线程数
  27.                 .multiFieldBatchPutConsumerThreadCount(1)
  28.                 // 多值异步写入回调方法
  29.                 .listenMultiFieldBatchPut(callback)
  30.                 .config();
  32.         // 特别注意，TSDB只需初始化一次即可
  33.         TSDB tsdb = TSDBClientFactory.connect(config);
  35.         MultiFieldPoint point = MultiFieldPoint
  36.                 .metric("test-test-test")
  37.                 .tag("a", "1")
  38.                 .tag("b", "2")
  39.                 .timestamp(System.currentTimeMillis())
  40.                 .field("f1", Math.random())
  41.                 .field("f2", Math.random())
  42.                 .build();
  43.         tsdb.multiFieldPut(point);
  45.         // 特别注意，在应用生命周期内不用关闭TSDB实例，直到应用结束时关闭即可
  46.         tsdb.close();
  47.     }

使用摘要回调方法

摘要回调方法，当写入成功时，报告这次写入成功时的数据点列表，以及对应的写入摘要情况，包括成功点数，失败点数；当写入失败时，报告这次写入失败时的数据点列表以及对应的写入异常。

示例代码：

  1.       // 创建一个摘要回调方法，用于处理写入成功或者失败后的情况
  2.       AbstractMultiFieldBatchPutCallback callback = new MultiFieldBatchPutSummaryCallback() {
  4.             final AtomicInteger num = new AtomicInteger();
  5.             @Override
  6.             public void response(String address, List<MultiFieldPoint> points, SummaryResult result) {
  7.                 int count = num.addAndGet(points.size());
  8.                 System.out.println(result);
  9.                 System.out.println("已处理" + count + "个点");
  10.             }
  14.             @Override
  15.             public void failed(String address, List<MultiFieldPoint> points, Exception ex) {
  16.                 System.err.println("业务回调出错！" + points.size() + " error!");
  17.                 ex.printStackTrace();
  18.             }
  19.         };
  21.        TSDBConfig config = TSDBConfig.address("127.0.0.1", 8242)
  22.                 .httpConnectTimeout(90)
  23.                 // 批次写入时每次提交数据量
  24.                 .batchPutSize(500)
  25.                 // 单值异步写入线程数
  26.                 .batchPutConsumerThreadCount(1)
  27.                 // 多值异步写入缓存队列长度
  28.                 .multiFieldBatchPutBufferSize(10000)
  29.                 // 多值异步写入线程数
  30.                 .multiFieldBatchPutConsumerThreadCount(1)
  31.                 // 多值异步写入回调方法
  32.                 .listenMultiFieldBatchPut(callback)
  33.                 .config();
  35.         // 特别注意，TSDB只需初始化一次即可
  36.         TSDB tsdb = TSDBClientFactory.connect(config);
  38.         MultiFieldPoint point = MultiFieldPoint
  39.                 .metric("test-test-test")
  40.                 .tag("a", "1")
  41.                 .tag("b", "2")
  42.                 .timestamp(System.currentTimeMillis())
  43.                 .field("f1", Math.random())
  44.                 .field("f2", Math.random())
  45.                 .build();
  46.         tsdb.multiFieldPut(point);
  48.         // 特别注意，在应用生命周期内不用关闭TSDB实例，直到应用结束时关闭即可
  49.         tsdb.close();
  50.     }

使用详情回调方法

详情回调方法，当写入成功时，报告这次写入成功时的数据点列表，以及对应的写入详情，包括写入失败的点以及对应错误信息等；当写入失败时，报告这次写入失败时的数据点列表以及对应的写入异常。示例代码：

  1.       // 创建一个详情回调方法，用于处理写入成功或者失败后的情况
  2.       MultiFieldBatchPutDetailsCallback callback = new MultiFieldBatchPutDetailsCallback() {
  4.             final AtomicInteger num = new AtomicInteger();
  6.             @Override
  7.             public void response(String address, List<MultiFieldPoint> points, DetailsResult result) {
  8.                 int count = num.addAndGet(points.size());
  9.                 System.out.println(result);
  10.                 System.out.println("已处理" + count + "个点");
  11.             }
  13.             @Override
  14.             public void failed(String address, List<MultiFieldPoint> points, Exception ex) {
  15.                 System.err.println("业务回调出错！" + points.size() + " error!");
  16.                 ex.printStackTrace();
  17.             }
  18.         };
  20.        TSDBConfig config = TSDBConfig.address("127.0.0.1", 8242)
  21.                 .httpConnectTimeout(90)
  22.                 // 批次写入时每次提交数据量
  23.                 .batchPutSize(500)
  24.                 // 单值异步写入线程数
  25.                 .batchPutConsumerThreadCount(1)
  26.                 // 多值异步写入缓存队列长度
  27.                 .multiFieldBatchPutBufferSize(10000)
  28.                 // 多值异步写入线程数
  29.                 .multiFieldBatchPutConsumerThreadCount(1)
  30.                 // 多值异步写入回调方法
  31.                 .listenMultiFieldBatchPut(callback)
  32.                 .config();
  34.         // 特别注意，TSDB只需初始化一次即可
  35.         TSDB tsdb = TSDBClientFactory.connect(config);
  37.         MultiFieldPoint point = MultiFieldPoint
  38.                 .metric("test-test-test")
  39.                 .tag("a", "1")
  40.                 .tag("b", "2")
  41.                 .timestamp(System.currentTimeMillis())
  42.                 .field("f1", Math.random())
  43.                 .field("f2", Math.random())
  44.                 .build();
  45.         tsdb.multiFieldPut(point);
  47.         // 特别注意，在应用生命周期内不用关闭TSDB实例，直到应用结束时关闭即可
  48.         tsdb.close();
  49.     }
版权声明

本文仅代表作者观点，不代表本站立场。
本文系作者授权发表，未经许可，不得转载。

评论

-----