Amazon Redshift は、パッチ 198 以降、新しい Python UDF の作成をサポートしなくなります。既存の Python UDF は、2026 年 6 月 30 日まで引き続き機能します。詳細については、[ブログ記事](https://aws.amazon.com/blogs/big-data/amazon-redshift-python-user-defined-functions-will-reach-end-of-support-after-june-30-2026/)を参照してください。
# SYS\_STREAM\_SCAN\_STATES
ストリーミング取り込みによってロードされたレコードのスキャン状態を記録します。
SYS\_STREAM\_SCAN\_STATES はすべてのユーザーに表示されます。スーパーユーザーはすべての行を表示できますが、通常のユーザーは自分のデータのみを表示できます。詳細については、「[システムテーブルとビューのデータの可視性](cm_chap_system-tables.md#c_visibility-of-data)」を参照してください。
## テーブルの列
| 列名 | データ型 | 説明 |
| --- | --- | --- |
| 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)
```