Menulis data deret waktu menggunakan Tablestore SDK untuk Python - Tablestore

Setelah membuat tabel deret waktu, Anda dapat memanggil operasi PutTimeseriesData untuk menulis satu atau lebih baris data deret waktu ke tabel secara bersamaan.

Catatan penggunaan

Fitur model TimeSeries didukung oleh Tablestore SDK untuk Python versi V6.1.0 dan yang lebih baru. Pastikan Anda menggunakan versi Tablestore SDK untuk Python yang sesuai.

Catatan

Untuk informasi lebih lanjut, lihat Riwayat versi Tablestore SDK untuk Python.

Prasyarat

Klien harus diinisialisasi terlebih dahulu. Untuk detail lebih lanjut, lihat Menginisialisasi klien Tablestore.

Parameter

Parameter

Deskripsi

timeseriesTableName (wajib)

Nama tabel deret waktu.

timeseriesRows (wajib)

Daftar data deret waktu. Baris data deret waktu terdiri dari pengenal deret waktu dan data deret waktu.

timeseries_key (wajib): pengenal deret waktu, yang terdiri dari item-item berikut:
- measurement_name (wajib): Nama metrik dari deret waktu.
- data_source (wajib): Informasi sumber data.
- tags (wajib): Informasi tag dari deret waktu, yang terdiri dari beberapa pasangan kunci-nilai.
time_in_us (wajib): Cap waktu titik data. Satuan: mikrodetik.
fields (wajib): Titik-titik data, yang terdiri dari beberapa kunci bidang dan nilai bidang.

Contoh

Berikut adalah contoh kode untuk menulis beberapa baris data deret waktu ke tabel deret waktu:

# Informasi tag dari deret waktu.
tags = {"tag1": "t1", "tag2": "t2"}
# Pengenal deret waktu.
key1 = TimeseriesKey("measure1", "datasource1", tags)
key2 = TimeseriesKey("measure2", "datasource2", tags)
# Data deret waktu.
field1 = {"long_field": 1, "string_field": "string", "bool_field": True, "double_field": 0.3}
field2 = {"binary_field2": bytearray(b'a')}

try:
    # Data deret waktu.
    row1 = TimeseriesRow(key1, field1, int(time.time() * 1000000))
    row2 = TimeseriesRow(key2, field2, int(time.time() * 1000000))
    rows = [row1, row2]

    # Panggil operasi untuk menulis data deret waktu.
    ots_client.put_timeseries_data("", rows)
    print("penulisan data deret waktu berhasil.")
except Exception as e:
    # Jika terjadi pengecualian, operasi gagal. Tangani pengecualian.
    print("penulisan data deret waktu gagal. %s" % e)