Menulis data deret waktu menggunakan Tablestore SDK untuk Python - Tablestore

Setelah membuat tabel deret waktu, panggil operasi PutTimeseriesData untuk menulis satu atau beberapa baris data deret waktu ke dalam tabel tersebut.

Catatan penggunaan

Model TimeSeries memerlukan Tablestore SDK untuk Python versi 6.1.0 atau yang lebih baru.

Catatan

Untuk informasi selengkapnya, lihat Riwayat versi Python SDK.

Prasyarat

Sebelum memulai, pastikan Anda telah:

Klien Tablestore yang telah diinisialisasi. Untuk informasi selengkapnya, lihat Inisialisasi klien Tablestore.

Parameter

Parameter

Deskripsi

timeseriesTableName (wajib)

Nama tabel deret waktu.

timeseriesRows (wajib)

Daftar baris deret waktu yang akan ditulis. Setiap baris terdiri dari pengenal deret waktu dan data terkait.

timeseries_key (wajib): pengenal deret waktu, yang terdiri dari bidang-bidang berikut:
- measurement_name (wajib): Nama metrik dari deret waktu.
- data_source (wajib): Pengenal sumber data.
- tags (wajib): Tag untuk deret waktu, ditentukan sebagai pasangan kunci-nilai.
time_in_us (wajib): Timestamp titik data, dalam mikrodetik.
fields (wajib): Titik data, ditentukan sebagai pasangan kunci-nilai bidang.

Contoh

Contoh berikut menulis dua baris data deret waktu ke dalam tabel deret waktu:

# Definisikan tag untuk mengidentifikasi deret waktu
tags = {"tag1": "t1", "tag2": "t2"}

# Buat pengenal deret waktu
key1 = TimeseriesKey("measure1", "datasource1", tags)
key2 = TimeseriesKey("measure2", "datasource2", tags)

# Definisikan titik data untuk setiap deret waktu
field1 = {"long_field": 1, "string_field": "string", "bool_field": True, "double_field": 0.3}
field2 = {"binary_field2": bytearray(b'a')}

try:
    # Bangun baris deret waktu dengan timestamp dalam mikrodetik
    row1 = TimeseriesRow(key1, field1, int(time.time() * 1000000))
    row2 = TimeseriesRow(key2, field2, int(time.time() * 1000000))
    rows = [row1, row2]

    # Tulis baris-baris tersebut ke tabel deret waktu
    ots_client.put_timeseries_data("", rows)
    print("put timeseries data succeeded.")
except Exception as e:
    print("put timeseries data failed. %s" % e)