Amazon Redshift non supporterà più la creazione di nuovi Python UDFs a partire dalla Patch 198. Python esistente UDFs continuerà a funzionare fino al 30 giugno 2026. Per ulteriori informazioni, consulta il post del blog
Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
SYS_STREAM_SCAN_STATES
Registra gli stati di scansione dei record caricati tramite l'importazione dati in streaming.
SYS_STREAM_SCAN_STATES è visibile a tutti gli utenti. Gli utenti con privilegi avanzati visualizzano tutte le righe; gli utenti regolari visualizzano solo i propri dati. Per ulteriori informazioni, consultare Visibilità dei dati nelle tabelle e nelle viste di sistema.
Colonne di tabella
| Nome della colonna | Tipo di dati | Description |
|---|---|---|
| external_schema_name | character(128) | Nome dello schema esterno. Applica la distinzione tra lettere maiuscole e minuscole. |
| stream_name | character(255) | Il nome del flusso. Applica la distinzione tra lettere maiuscole e minuscole. |
| mv_name | character(128) | Nome della vista materializzata associata. È vuoto se non è presente un nome. Applica la distinzione tra lettere maiuscole e minuscole. |
| transaction_id | bigint | L'ID transazione. |
| query_id | bigint | L'ID di query. |
| record_time | timestamp without time zone | Ora della registrazione dei dati. |
| partition_id | character(128) | ID della partizione. Applica la distinzione tra lettere maiuscole e minuscole. |
| latest_position | character(128) | Posizione dell'ultimo record letto nel batch. Corrisponde al numero di sequenza in Kinesis o all'offset in Amazon MSK. Applica la distinzione tra lettere maiuscole e minuscole. |
| scanned_rows | bigint | Numero di record analizzati nel batch. |
| skipped_rows | bigint | Numero di record che sono stati ignorati nel batch. |
| scanned_bytes | bigint | Numero di byte analizzati nel batch. |
| stream_record_time_min | timestamp without time zone | Ora minima di arrivo del primo record del batch in Kinesis o Amazon MSK. |
| stream_record_time_max | timestamp without time zone | Ora massima di arrivo dell'ultimo record del batch in Kinesis o Amazon MSK. |
La seguente query mostra i dati relativi ai flussi e agli argomenti per query specifiche.
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)
