我有带有 unix 纪元时间戳的事件,我正在使用带有 Kinesis 连接器的表作为源表。我需要使用与水印相同的时间戳字段。我如何在python中做到这一点?我正在使用 Flink-1.11 版本,因为那是最新的 AWS 支持。
活动形式: {'event_time': 1633098843692, 'ticker': 'AMZN'}
Python 表:
CREATE TABLE event_input_table (
event_time TIMESTAMP,
ticker VARCHAR,
WATERMARK FOR event_time AS event_time - INTERVAL '5' SECOND
)
WITH (
'connector' = 'kinesis',
'stream' = 'inputstream1',
'aws.region' = 'us-east-1',
'scan.stream.initpos' = 'TRIM_HORIZON',
'format' = 'json' ,
'aws.credentials.provider' = 'ENV_VAR'
)