Lindorm:LindormTSDB へのデータの書き込み

LindormTSDB SDK for Java を使用してデータを書き込む

LindormTSDB SDK for Java は、Java を使用してアプリケーションを開発する開発者向けです。 LindormTSDB SDK for Java を使用して LindormTSDB にデータを書き込む方法の詳細については、「チュートリアル: LindormTSDB SDK for Java を使用して LindormTSDB に接続して使用する」をご参照ください。

例

// LindormTSDB のエンドポイントを指定します。
String url = "http://ld-bp17j28j2y7pm****-proxy-tsdb-pub.lindorm.rds.aliyuncs.com:8242";
// LindormTSDB クライアントを作成します。 LindormTSDB クライアントはスレッドセーフであり、再利用できます。 スレッドごとにクライアントを作成し、操作が完了した後にクライアントをシャットダウンする必要はありません。
ClientOptions options = ClientOptions.newBuilder(url).build();
LindormTSDBClient lindormTSDBClient = LindormTSDBFactory.connect(options);

// データベースとテーブルを作成します。
lindormTSDBClient.execute("CREATE DATABASE demo");
lindormTSDBClient.execute("demo","CREATE TABLE sensor (device_id VARCHAR TAG,region VARCHAR TAG,time BIGINT,temperature DOUBLE,humidity DOUBLE,PRIMARY KEY(device_id))");

// LindormTSDB にデータを書き込みます。
int numRecords = 10;
List<Record> records = new ArrayList<>(numRecords);
long currentTime = System.currentTimeMillis();
for (int i = 0; i < numRecords; i++) {
    Record record = Record
        .table("sensor")
        .time(currentTime + i * 1000)
        .tag("device_id", "F07A1260")
        .tag("region", "north-cn")
        .addField("temperature", 12.1 + i)
        .addField("humidity", 45.0 + i)
        .build();
    records.add(record);
}
CompletableFuture<WriteResult> future = lindormTSDBClient.write("demo", records);
// 非同期で書き込まれたデータを処理します。
future.whenComplete((r, ex) -> {
    // 書き込みエラーを処理します。
    if (ex != null) {
        System.out.println("書き込みに失敗しました。");
        if (ex instanceof LindormTSDBException) {
            LindormTSDBException e = (LindormTSDBException) ex;
            System.out.println("LindormTSDBException が発生しました。これは、リクエストが Lindorm TSDB に到達しましたが、"
                               + "何らかの理由でエラー応答で拒否されたことを意味します。");
            System.out.println("エラーコード: " + e.getCode());
            System.out.println("SQL 状態:  " + e.getSqlstate());
            System.out.println("エラーメッセージ: " + e.getMessage());
        }  else {
            ex.printStackTrace();
        }
    } else  {
        System.out.println("書き込みに成功しました。");
    }
});
// この例では、テーブルに書き込まれたデータを処理するために、単純な同期操作が実行されます。
System.out.println(future.join());

InfluxDB® ラインプロトコルを使用してデータを書き込む

LindormTSDB では、InfluxDB® ラインプロトコルを使用してデータを書き込むことができます。 アプリケーションが Java を使用して開発されていない場合は、ラインプロトコルを使用して LindormTSDB にデータを書き込むことをお勧めします。 ラインプロトコルを使用してデータを書き込むときに、スキーマ制約ポリシーを設定できます。 デフォルトでは、スキーマ制約ポリシーは弱制約です。 詳細については、「InfluxDB ラインプロトコルを使用したデータの書き込み」をご参照ください。

例

curl -X POST \
'http://ld-bp1489gr5t*****-proxy-tsdb.lindorm.rds.aliyuncs.com:8242/api/v2/write?precision=ms&db=default' \
-d '
sensor7,device_id=F07A1260,region=north-cn temperature=12.1,humidity=45 1619076780000
sensor7,device_id=F07A1260,region=north-cn temperature=13.2,humidity=47 1619076790000
sensor7,device_id=F07A1260,region=north-cn temperature=10.6,humidity=46 1619076800000
sensor7,device_id=F07A1260,region=north-cn temperature=18.1,humidity=44 1619076780000
sensor7,device_id=F07A1260,region=north-cn temperature=19.7,humidity=44 1619076790000
'

標準 SQL ステートメントを使用してデータを書き込む

次の表に、SQL ステートメントを使用して LindormTSDB にデータを書き込むときに使用できる 2 つの方法を示します。

TSDB が提供する API オペレーションを使用してデータを書き込む

LindormTSDB は、TSDB の API オペレーションと互換性があります。 アプリケーションで TSDB を使用してデータを保存する場合は、TSDB が提供する API オペレーションを使用して LindormTSDB にデータを書き込むことができます。 次の表に、TSDB が提供する API オペレーションを使用してデータを書き込むときに使用できる 2 つの方法を示します。

Prometheus のリモート書き込みインターフェースを使用してデータを書き込む

LindormTSDB は、Prometheus のリモートストレージとして使用できます。 リモート書き込みインターフェースを使用して LindormTSDB にデータを書き込んだ後、PromQL ステートメントを使用してデータをクエリできます。 詳細については、「Prometheus を使用して LindormTSDB に接続して使用する」をご参照ください。

Apache Flink を使用してデータを書き込む

LindormTSDB SDK for Java を統合する Sink コネクタを使用して、LindormTSDB にデータを書き込むことができます。 詳細については、「Flink を使用して LindormTSDB にデータを書き込む」をご参照ください。