Я хочу подключить поток Kinesis к функции Lambda через сопоставление источников событий, хочу установить для StartingPosition
значение AT_TIMESTAMP
-
Итак, теперь я хочу установить фактическую отметку времени для этой начальной позиции.
Если я посмотрю на интерфейс командной строки AWS, похоже, для него есть параметр (--starting-position-timestamp
) -
aws lambda create-event-source-mapping help
SYNOPSIS
create-event-source-mapping
--event-source-arn <value>
--function-name <value>
[--enabled | --no-enabled]
[--batch-size <value>]
[--starting-position <value>]
[--starting-position-timestamp <value>]
[--cli-input-json <value>]
[--generate-cli-skeleton <value>]
и если я посмотрю на boto3
, там будет параметр StartingPositionTimestamp
-
response = client.create_event_source_mapping(
EventSourceArn='string',
FunctionName='string',
Enabled=True|False,
BatchSize=123,
StartingPosition='TRIM_HORIZON'|'LATEST'|'AT_TIMESTAMP',
StartingPositionTimestamp=datetime(2015, 1, 1)
)
но я не могу найти такой StartingPositionTimestamp
параметр в AWS::Lambda::EventSourceMapping
документах -
Итак, как мне установить временную метку начальной позиции Kinesis с помощью Cloudformation?
LATEST
илиTRIM_HORIZON
, поскольку Kinesis хранит ваши события только в течение определенного периода (из-заretention period
). Кроме того, у меня такое ощущение, что CloudFormation вообще не поддерживает установкуStartingPositionTimestamp
в этом случае (но у меня нет доказательств этого). - person s.hesse   schedule 21.08.2019TRIM_HORIZON
. Но зачемAT_TIMESTAMP
, если вы не можете указать временную метку ?? - person Justin   schedule 21.08.2019