Как создать расширенного потребителя Kinesis для лямбда-выражения

Я хочу использовать лямбда (python) для чтения данных из потока данных Kinesis и передачи их в другой поток данных Kinesis. Я хочу создать расширенного потребителя разветвления для исходного потока, чтобы его можно было использовать лямбда-функцией. Может ли кто-нибудь сообщить мне, как это можно сделать, или указать мне на некоторую четкую документацию, поскольку мне не очень повезло, пытаясь найти простой учебник или способ.


aws-lambda amazon-kinesis
person Maarab    schedule 03.05.2020    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Вы можете создать потребителя через интерфейс командной строки AWS, например

aws kinesis register-stream-consumer --stream-arn arn:aws:kinesis:us-west-2:123:stream/my_foo_stream --consumer-name FooConsumer

# Response
{
    "Consumer": {
        "ConsumerName": "FooConsumer",
        "ConsumerARN": "arn:aws:kinesis:us-west-2:123:stream/staging_transactions/consumer/FooConsumer:12345",
        "ConsumerStatus": "CREATING",
        "ConsumerCreationTimestamp": "2021-02-17T16:53:51-05:00"
    }
}

После этого шага вы должны увидеть своего потребителя разветвления на вкладке «Расширенное разветвление» в потоке Kinesis, а также в конфигурациях лямбда-выражений при добавлении нового триггера Kinesis в разделе «Потребитель».

https://docs.aws.amazon.com/cli/latest/reference/kinesis/register-stream-consumer.html.

person pllx    schedule 17.02.2021