如何为 lambda 创建 Kinesis 增强型扇出使用者答案

【问题标题】：How to create a Kinesis enhanced fan-out consumer for lambda如何为 lambda 创建 Kinesis 增强型扇出使用者
【发布时间】：2021-02-18 06:09:56
【问题描述】：

我想使用 lambda (python) 从 Kinesis 数据流中读取数据并将其推送到另一个 Kinesis 数据流。我想为源流创建一个增强的扇出使用者，以便它可以被 lambda 函数使用。任何人都可以让我知道如何做到这一点，或者向我指出一些清晰的文档，因为我没有太多运气试图找到一个简单的教程或方法。

【问题讨论】：

标签： aws-lambda amazon-kinesis

【解决方案1】：

您可以通过 AWS CLI 创建消费者，例如

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 Stream 的“增强型扇出”选项卡下看到您的扇出使用者，当您在“使用者”下添加新的 Kinesis 触发器时，您也应该在 Lambda 配置中看到您的扇出使用者。

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

【讨论】：