Python 用 Tablestore SDK を使用した時系列データの書き込み - Tablestore

時系列テーブルを作成した後、PutTimeseriesData 操作を呼び出して、1 つ以上の時系列データ行をテーブルに同時に書き込むことができます。

使用上の注意

TimeSeries モデルの機能は、Python 用 Tablestore SDK V6.1.0 以降でサポートされています。正しいバージョンの Python 用 Tablestore SDK を使用していることを確認してください。

説明

詳細については、「Python 用 Tablestore SDK のバージョン履歴」をご参照ください。

前提条件

クライアントが初期化されていること。詳細については、「Tablestore クライアントの初期化」をご参照ください。

パラメータ

パラメータ

説明

timeseriesTableName (必須)

時系列テーブルの名前。

timeseriesRows (必須)

時系列データのリスト。時系列データの行は、時系列識別子と時系列データで構成されます。

timeseries_key (必須): 時系列識別子。以下の項目で構成されます。
- measurement_name (必須): 時系列のメトリック名。
- data_source (必須): データソース情報。
- tags (必須): 時系列のタグ情報。複数のキーと値のペアで構成されます。
time_in_us (必須): データポイントのタイムスタンプ。単位: マイクロ秒。
fields (必須): データポイント。複数のフィールドキーとフィールド値で構成されます。

例

次のサンプルコードは、複数の時系列データ行を時系列テーブルに書き込む方法の例を示しています。

# 時系列のタグ情報
tags = {"tag1": "t1", "tag2": "t2"}
# 時系列識別子
key1 = TimeseriesKey("measure1", "datasource1", tags)
key2 = TimeseriesKey("measure2", "datasource2", tags)
# 時系列データ
field1 = {"long_field": 1, "string_field": "string", "bool_field": True, "double_field": 0.3}
field2 = {"binary_field2": bytearray(b'a')}

try:
    # 時系列データ
    row1 = TimeseriesRow(key1, field1, int(time.time() * 1000000))
    row2 = TimeseriesRow(key2, field2, int(time.time() * 1000000))
    rows = [row1, row2]

    # 時系列データを書き込む操作を呼び出します。
    ots_client.put_timeseries_data("", rows)
    print("put timeseries data succeeded.")
except Exception as e:
    # 例外がスローされた場合、操作は失敗します。例外を処理します。
    print("put timeseries data failed. %s" % e)