Amazon Redshift dejará de admitir la creación de nuevas UDF de Python a partir del 1 de noviembre de 2025. Si desea utilizar las UDF de Python, créelas antes de esa fecha. Las UDF de Python existentes seguirán funcionando con normalidad. Para obtener más información, consulte la publicación del blog
SYS_STREAM_SCAN_STATES
Registra los estados de exploración de los registros cargados mediante la ingesta de streaming.
SYS_STREAM_SCAN_STATES es visible para todos los usuarios. Los superusuarios pueden ver todas las filas; los usuarios normales solo pueden ver sus datos. Para obtener más información, consulte Visibilidad de datos en las tablas y vistas de sistema.
Columnas de la tabla
| Nombre de la columna | Tipo de datos: | Descripción |
|---|---|---|
| external_schema_name | character (128) | El nombre del esquema externo. Distingue entre mayúsculas y minúsculas. |
| stream_name | character(255) | El nombre de la transmisión. Distingue entre mayúsculas y minúsculas. |
| mv_name | character (128) | Nombre de la vista materializada asociada. Está vacío si no hay ninguna. Distingue entre mayúsculas y minúsculas. |
| transaction_id | bigint | El ID de la transacción. |
| query_id | bigint | El ID de la consulta. |
| record_time | TIMESTAMP sin zona horaria | Hora en que se registraron los datos. |
| partition_id | character (128) | Identificador de la partición. Distingue entre mayúsculas y minúsculas. |
| latest_position | character (128) | Posición del último registro leído en el lote. Se corresponde con el número de secuencia en Kinesis o el desplazamiento en Amazon MSK. Distingue entre mayúsculas y minúsculas. |
| scanned_rows | bigint | Número de registros que se han explorado en el lote. |
| skipped_rows | bigint | Número de registros que se han omitido en el lote. |
| scanned_bytes | bigint | Número de bytes que se han explorado en el lote. |
| stream_record_time_min | TIMESTAMP sin zona horaria | Hora de llegada de Kinesis o Amazon MSK para el registro más antiguo del lote. |
| stream_record_time_max | TIMESTAMP sin zona horaria | Hora de llegada de Kinesis o Amazon MSK para el registro más reciente del lote. |
En la siguiente consulta se muestran los datos de flujo y de tema para consultas específicas.
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)
