SYS_STREAM_SCAN_STATES - Amazon Redshift

Amazon Redshift tidak akan lagi mendukung pembuatan Python UDFs baru mulai 1 November 2025. Jika Anda ingin menggunakan Python UDFs, buat UDFs sebelum tanggal tersebut. Python yang ada UDFs akan terus berfungsi seperti biasa. Untuk informasi lebih lanjut, lihat posting blog.

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

SYS_STREAM_SCAN_STATES

Catatan memindai status untuk catatan yang dimuat melalui konsumsi streaming.

SYS_STREAM_SCAN_STATES dapat dilihat oleh semua pengguna. Pengguna super dapat melihat semua baris; pengguna biasa hanya dapat melihat data mereka sendiri. Untuk informasi selengkapnya, lihat Visibilitas data dalam tabel dan tampilan sistem.

Kolom tabel

Nama kolom Jenis data Deskripsi
external_schema_name karakter (128) Nama skema eksternal. Ini peka huruf besar/kecil.
stream_name karakter (255) Nama stream. Ini peka huruf besar/kecil.
mv_nama karakter (128) Nama tampilan terwujud terkait. Kosong jika tidak ada. Ini peka huruf besar/kecil.
transaction_id bigint ID transaksi.
query_id bigint ID kueri.
record_time stempel waktu tanpa zona waktu Waktu ketika data dicatat.
partisi_id karakter (128) Partisi atau shard id. Ini peka huruf besar/kecil.
posisi terbaru_ karakter (128) Posisi catatan terakhir dibaca dalam batch. Ini sesuai dengan nomor urut di Kinesis atau offset di Amazon MSK. Ini peka huruf besar/kecil.
scanned_rows bigint Jumlah catatan yang dipindai dalam batch.
lewat_rows bigint Jumlah catatan yang dilewati dalam batch.
scanned_bytes bigint Jumlah byte yang dipindai dalam batch.
stream_record_time_min stempel waktu tanpa zona waktu Kinesis atau waktu kedatangan MSK Amazon untuk catatan paling awal dalam batch.
stream_record_time_max stempel waktu tanpa zona waktu Kinesis atau waktu kedatangan MSK Amazon untuk catatan terbaru dalam batch.

Kueri berikut menunjukkan aliran dan data topik untuk kueri tertentu.

select query_id,mv_name::varchar,external_schema_name::varchar,stream_name::varchar,sum(scanned_rows) total_records, sum(scanned_bytes) total_bytes from sys_stream_scan_states where query in (5401180,8601939) group by 1,2,3,4; query_id | mv_name | external_schema_name | stream_name | total_records | total_bytes ------------+----------------+----------------------+-----------------+---------------+---------------- 5401180 | kinesistest | kinesis | kinesisstream | 1493255696 | 3209006490704 8601939 | msktest | msk | mskstream | 14677023 | 31056580668 (2 rows)