View a markdown version of this page

向订阅者重播保留的事件 - 亚马逊 EventBridge

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

向订阅者重播保留的事件

例如,要交付公交车已经举办的活动,请在总线的保留窗口内创建一个订阅者,--starting-position POINT_IN_TIME并在其保留期内设置一个起点--point-in-time-configuration '{ "PointType": "TIMESTAMP", "StartingPoint": "2026-09-01T00:00:00Z" }'。没有单独的重播 API:订阅者从其起始位置读取保留的事件,因此任何仍在保留期内的内容都可以再次交付。DescribeEventBus返回RetentionWindowStartTime,订阅者可以读取的最早点;在新总线上,即总线的创建时间,因此最近的时间戳仍然可以落在窗口外。有关保留期本身,请参阅选择保留期。

起始位置

创建订阅者时,--starting-position是LATEST仅接收订阅者存在后发布的事件,或者从保留POINT_IN_TIME的历史记录中读取。使用POINT_IN_TIME,--point-in-time-configuration设置PointType为HORIZON,最早保留的事件,或设置TIMESTAMP为StartingPoint。起点必须在保留期限内:在保留期内或之后RetentionWindowStartTime,而不是将来。此时,可选选项会EndPoint停止订阅者。省略后EndPoint,订阅者将阅读保留的事件,及时了解直播活动并继续交付。

aws eventsv2 create-subscriber \ --name reprocess-september \ --event-bus-arn arn:aws:events:us-east-1:111122223333:event-busv2/orders/EXAMPLE1234567890abcdef \ --starting-position POINT_IN_TIME \ --point-in-time-configuration '{ "PointType": "TIMESTAMP", "StartingPoint": "2026-09-01T00:00:00Z" }' \ --invoke-configuration '{ "TargetArn": "arn:aws:sqs:us-east-1:111122223333:reprocess", "RoleArn": "arn:aws:iam::111122223333:role/EventBusDeliveryRole" }'

重播具有启动延迟,然后以实时速度运行。在得出重放无法正常运行的结论之前,请稍等片刻。要暂停订阅者,然后在有或没有待办事项的情况下继续订阅,请参阅暂停和恢复。

区分重播的赛事

每个已交付的事件都会携带SystemMetadata."aws:DeliveryType",LIVE用于在事件到达时交付的事件以及从保留REPLAY的历史记录中读取的事件。使用它来使消费者在重播期间具有等效性。