标记有以下标签的问题： Amazon Kinesis
内容语言: 中文 (简体)
Select up to 5 tags to filter
排序方式 最新
浏览下面列出的问题和回答，或者筛选和排序以缩小结果范围。
【以下的问题经过翻译处理】 客户目前正在爬去数据并写入S3，再加载到Amazon OpenSearch。当前架构如下。
ECS-> EC2-> S3-> EC2->...
【以下的问题经过翻译处理】...
【以下的问题经过翻译处理】 有没有第三方工具可以帮助客户操作管理Kinesis数据流？例如，如果客户有数十个Kinesis流，除了使用控制台和CloudWatch，是否存在图形化工具以帮助管理多个Kinesis流的运维管理负担。
【以下的问题经过翻译处理】 使用Kinesis增强型扇出时，可以订阅单独的分片。我想了解下当进行重新分片时，消费者会发生什么？
【以下的问题经过翻译处理】 我有一个事件处理架构，基本上是KPL Producer -> Kinesis Data Streams(Raw) -> KDA(Flink Aggregation) -> Kinesis Data Streams(Agg) -> Lambda -> Timestream。使用10个Raw Shards的基本设置，Flink应用程序上有2个KPU，并使用5个Agg...
【以下的问题经过翻译处理】 我的程序的主要目的是连接到一个传入的MQTT通道，并将接收到的数据发送到我的AWS Kinesis流中，名称为"MyKinesisStream"。
下面是我的代码：
import argparse
import logging
import random
from paho.mqtt import client as mqtt_client
from...
【以下的问题经过翻译处理】 我正在开展一项需要消息顺序的物联网项目，例如监测大楼里的电梯。当电梯从第一层到第十层移动时，需要接收到每个楼层的MQTT消息。
目前的问题是：如果代理基于ACK无法保证消息序列，那么我的模拟/消费者可能会获得1、2、3、[9]、4、5、6、7、8、10等楼层数。因此，这种情况下无法进行实时监测。如果是这种情况，有哪些好的IoT...
【以下的问题经过翻译处理】...
【以下的问题经过翻译处理】 客户目前在自己的物联网服务中使用Kinesis（我猜是data stream）。
客户确信KCL记录了EC2在缩放或终止时如何处理数据。（当数据被处理时可能会终止EC2）
**Q1)** 他们想知道这个记录是如何处理的？
或者
**Q2)** 他们必须在EC2被缩放时设置生命周期钩子，或者KCL能自己管理这个记录？
客户想要例子或实践。
【以下的问题经过翻译处理】 你好，
我有一个客户想要将太阳能发电机的传感器数据写入S3。 数据流通常发生在白天，夜间几乎没有数据。 白天的传输速度可能约为 1MB/秒。 它可能会变化到 5MB 或更多，具体取决于部署的发电机区域中有多少太阳能电池板。
由于太阳能发电机通常位于山区，因此有时可能会断网。
他们希望将传感器数据保存到 S3，因为那里都是只读数据。 他们还将使用 SageMaker...
【以下的问题经过翻译处理】 在EventBridge中，我有一个Event Bus和2个规则。在Kinesis中，我有一个Data Stream。
其中一个规则的目标是CloudWatch中的一个Log Group。第二个规则的目标是我在Kinesis中的Data Stream。这个规则有一个带有策略的角色，执行我Data Stream上需要的所有操作。
当我去我的Event...
【以下的问题经过翻译处理】 我正在关注 [AWS CloudWatch Logs - 设置新的跨账户订阅](https://docs.amazonaws.cn/en_us/AmazonCloudWatch/latest/logs/Cross-Account-Log_Subscription-New.html)，参考该文档我能够从账户 A 获取 WAF 日志，并传输到账户 B 中的...