标记有以下标签的问题： 亚马逊托管的 Apache Flink 服务

【以下的问题经过翻译处理】 我有一个事件处理架构，基本上是KPL Producer -> Kinesis Data Streams(Raw) -> KDA(Flink Aggregation) -> Kinesis Data Streams(Agg) -> Lambda -> Timestream。使用10个Raw Shards的基本设置，Flink应用程序上有2个KPU，并使用5个Agg Sha...

【以下的问题经过翻译处理】 有几个桌面应用程序，包括Windows/Mac/Nix等平台，这些应用程序生成JSON事件，通过POST方式发布这些事件。目前这是一个单向的交易，应用程序向流输出数据仅用于分析。我们现在想要分析这些事件，以确定是否存在可操作的“数据序列”开始出现。 在以下目的下，将这些记录（250-500字节，每秒最高1,000）流式传输到AWS的最有效（第1-性能，第2-成本，第...

【以下的问题经过翻译处理】 是否可以创建多个Kinesis数据分析应用程序 （Kinesis Data Analytics apps）并使用相同的数据源，即Kinesis Firehose数据传送流？当多个Analytics应用程序从Firehose流中获取数据时，是否存在流量限制的问题？

【以下的问题经过翻译处理】 一位数据科学家正在寻求在SageMaker中托管一个TensorFlow模型，并处理低容量的流式事件数据（约每秒2-3个）以收集有关每个事件的推理。数据科学家正在考虑将SageMaker推理模型插入为Kinesis Data Analytics应用程序，但Kinesis Data Analytics目前仅支持SQL或Flink。 一种选项是设置一个ECS或Lambda...

【以下的问题经过翻译处理】 一位客户正在构建一种流式解决方案，用于处理客户发送的消息。流中的数据来自多个客户 - 每个流中的JSON都有一个customerId，告诉你最初是哪个客户发送了数据。 他们想将这些数据存储在S3上，但是按customerId进行分区。我们可以使用多个Firehose（每个customerId一个）来实现这一点。在Flink中是否可以实现这一点 - 使用Flink从Ki...

【以下的问题经过翻译处理】 一个连接到Kinesis Firehose的Lambda数据转换函数能否通过Athena在S3中的数据与Kinesis Firehose中的流式数据进行连结，并将结果传递给Kinesis Analytics进行进一步处理？这个功能是否被支持？

【以下的问题经过翻译处理】 用户希望构建一个实时应用程序，其中的数据存储在Kafka集群中。Kafka正在AWS上运行，不使用MSK而是使用K8S。如何将Kinesis数据分析Flink应用程序与Kafka集成所需的步骤是什么？