SYS_STREAM_SCAN_STATES - Amazon Redshift
表列
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

SYS_STREAM_SCAN_STATES

记录通过串流摄取加载的记录的扫描状态。

SYS_STREAM_SCAN_STATES 对所有用户可见。超级用户可以查看所有行；普通用户只能查看其自己的数据。有关更多信息，请参阅 系统表和视图中的数据可见性。

表列

列名称 数据类型 描述
external_schema_name character(128) 外部模式名称。区分大小写。
stream_name character(255) 流名称。区分大小写。
mv_name character(128) 关联的实体化视图的名称。如果无关联视图，则为空。区分大小写。
transaction_id bigint 事务 ID。
query_id bigint 查询 ID。
record_time 不带时区的时间戳 记录数据的时间。
partition_id character(128) 分区或分片 ID。区分大小写。
latest_position character(128) 批次中读取的最后一条记录的位置。这对应于 Kinesis 中的序列号或 Amazon MSK 中的偏移。区分大小写。
scanned_rows bigint 批次中扫描的记录数。
skipped_rows bigint 批次中跳过的记录数。
scanned_bytes bigint 批次中扫描的字节数。
stream_record_time_min 不带时区的时间戳 批次中最早记录的 Kinesis 或 Amazon MSK 抵达时间。
stream_record_time_max 不带时区的时间戳 批次中最晚记录的 Kinesis 或 Amazon MSK 抵达时间。

以下查询显示了特定查询的串流和主题数据。

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)