文档

写入

更新时间:

Timestream提供了数据点和元数据的写入接口。

数据点写入

Timestream提供了同步和异步两种数据点写入方式。其中异步接口的底层是通过TableStoreWriter来写入,其写入吞吐能力更高,对延时不是特别敏感的业务建议使用异步接口。

元数据写入

Timestream支持元数据同步写入。Timestream支持写入和删除元数据。

重要

写入时间线元数据会覆盖该时间线元数据的原有数据。

示例代码

  1. 写入数据点。

            // 构造时间线标识。
            TimestreamIdentifier identifier = new TimestreamIdentifier.Builder("cpu")
                    .addTag("Role", "OTSServer")
                    .build();
            // 构造数据点,支持多个值。
            Point point = new Point.Builder(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
                    .addField("a1", 1)
                    .addField("a2", true)
                    .addField("a3", 12.0)
                    .addField("a4", "value")
                    .build();
    
            // 数据表操作对象。
            TimestreamDataTable dataTable = db.dataTable(dataTableName);
            // 同步写入数据。
            try {
              dataTable.write(
                      meta.getIdentifier(),
                      point);
            } catch (TableStoreException e) {
                // 异常处理。
            }
            // 异步写入数据。
            dataTable.asyncWrite(
                    meta.getIdentifier(),
                    point);
  2. 写入时间线元数据。

            // 构造时间线标识。
            TimestreamIdentifier identifier = new TimestreamIdentifier.Builder("cpu")
                    .addTag("Role", "OTSServer")
                    .build();
            // 构造时间线元数据。
            TimestreamMeta meta = new TimestreamMeta(identifier).addAttribute("a1", "");
            TimestreamMetaTable metaTable = db.metaTable();
            // 同步写入时间线元数据。
            metaTable.put(meta);
  3. 删除时间线元数据。

            // 构造时间线标识。
            TimestreamIdentifier identifier = new TimestreamIdentifier.Builder("cpu")
                    .addTag("Role", "OTSServer")
                    .build();
            TimestreamMetaTable metaTable = db.metaTable();
            // 同步删除时间线元数据。
            metaTable.delete(identifier);
  • 本页导读 (1)
文档反馈