Tablestore:時系列データのクエリ

前提条件

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

パラメーター

次の表は、request に含まれるパラメーターについて説明しています。

例

次のサンプルコードは、時系列テーブルで指定された条件を満たす時系列データをクエリする方法の例を示しています。

# 時系列のタグ情報。
tags = {"tag1": "t1", "tag2": "t2"}
# 時系列の識別子。
key = TimeseriesKey("measure1", "datasource1", tags)

try:
    request = GetTimeseriesDataRequest("")
    # 時系列の識別子。
    request.timeseriesKey = key
    # クエリ対象期間の終了タイムスタンプ。
    request.endTimeInUs = int(time.time() * 1000000)
    # リクエストで返される最大行数。
    request.limit = 20
    # 取得する列。このパラメーターを指定しない場合は、すべての列が返されます。
    request.fieldsToGet = {"string_field": DataType.STRING, "long_field": DataType.LONG}

    # 操作を呼び出して、時系列データをクエリします。
    response = ots_client.get_timeseries_data(request)
    print(response.rows)

    # nextToken が空でない場合は、次のリクエストを開始できます。
    if response.nextToken is not None:
        # nextToken を取得します。
        next_token = response.nextToken

        # nextToken を永続化したり、フロントエンドページに転送したりする場合は、Base64 を使用して nextToken を文字列にエンコードして保存および転送できます。
        # トークン自体は文字列ではありません。 str(nextToken) を直接使用してトークンを文字列としてエンコードすると、トークン情報が失われます。
        token_as_string = base64.b64encode(next_token).decode('utf-8')
        # 文字列をバイトにデコードします。
        next_token_byte = base64.b64decode(token_as_string.encode('utf-8'))

        # 操作を呼び出して、時系列データをクエリします。
        request.nextToken = next_token
        response = ots_client.get_timeseries_data(request)
        print(response.rows)
    print("get timeseries data succeeded.") # 時系列データの取得に成功しました。
except Exception as e:
    # 例外がスローされた場合、呼び出しは失敗します。例外を処理します。
    print("get timeseries data failed. %s" % e) # 時系列データの取得に失敗しました。