使用AWS re:Post即您表示您同意 AWS re:Post 使用条款

All Content tagged with Amazon Kinesis

Amazon Kinesis makes it easy to collect, process, and analyze real-time, streaming data so you can get timely insights and react quickly to new information.

内容语言: 中文 (简体)

Select up to 5 tags to filter
排序方式 最新
59 条结果
【以下的问题经过翻译处理】 客户目前正在爬去数据并写入S3,再加载到Amazon OpenSearch。当前架构如下。 ECS-> EC2-> S3-> EC2-> AOS 看起来像他们很久以前就建立了这个流水线,想优化工作流程。他们正在使用ECS(他们将旧的C#代码容器化),通过EC2运行它以写入S3,然后使用另一个EC2实例将数据加载到ES中。这似乎是一个非常低效的解决方案。还似乎有很多关...
1
回答
0
点赞数
229
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 你好,我需要在服务端对rtsp流进行分析,并使用Rekognition进行进一步分析。这些流并不总是可用的。我正在遵循AWS的以下指南:<https://github.com/aws-samples/rekognition-streaming-video-events>。 问题是像以下命令一样使用不能处理间歇性流的命令: ``` ./kvs_gstreamer_sa...
1
回答
0
点赞数
78
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 有没有第三方工具可以帮助客户操作管理Kinesis数据流?例如,如果客户有数十个Kinesis流,除了使用控制台和CloudWatch,是否存在图形化工具以帮助管理多个Kinesis流的运维管理负担。
1
回答
0
点赞数
45
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 使用Kinesis增强型扇出时,可以订阅单独的分片。我想了解下当进行重新分片时,消费者会发生什么?
1
回答
0
点赞数
100
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 我有一个事件处理架构,基本上是KPL Producer -> Kinesis Data Streams(Raw) -> KDA(Flink Aggregation) -> Kinesis Data Streams(Agg) -> Lambda -> Timestream。使用10个Raw Shards的基本设置,Flink应用程序上有2个KPU,并使用5个Agg Sha...
1
回答
0
点赞数
75
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 我的程序的主要目的是连接到一个传入的MQTT通道,并将接收到的数据发送到我的AWS Kinesis流中,名称为"MyKinesisStream"。 下面是我的代码: import argparse import logging import random from paho.mqtt import client as mqtt_client from stream_m...
1
回答
0
点赞数
66
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 我正在开展一项需要消息顺序的物联网项目,例如监测大楼里的电梯。当电梯从第一层到第十层移动时,需要接收到每个楼层的MQTT消息。 目前的问题是:如果代理基于ACK无法保证消息序列,那么我的模拟/消费者可能会获得1、2、3、[9]、4、5、6、7、8、10等楼层数。因此,这种情况下无法进行实时监测。如果是这种情况,有哪些好的IoT Core的替代解决方案?可以直接使用Am...
1
回答
0
点赞数
55
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 我想使用EventBridge管道将来自各种Kinesis流的数据导入到另一个Kinesis流中。 看起来我可以创建一个使用Kinesis流作为源的管道,筛选出我需要的数据子集,并将其导入到另一个Kinesis流作为目标。 但问题是,似乎我必须为目标Kinesis流指定一个硬编码的分区键。我不能像EventBridge规则系统那样设置分区键路径吗?如果我必须硬编码分...
1
回答
0
点赞数
41
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 客户目前在自己的物联网服务中使用Kinesis(我猜是data stream)。 客户确信KCL记录了EC2在缩放或终止时如何处理数据。(当数据被处理时可能会终止EC2) **Q1)** 他们想知道这个记录是如何处理的? 或者 **Q2)** 他们必须在EC2被缩放时设置生命周期钩子,或者KCL能自己管理这个记录? 客户想要例子或实践。
1
回答
0
点赞数
48
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 你好, 我有一个客户想要将太阳能发电机的传感器数据写入S3。 数据流通常发生在白天,夜间几乎没有数据。 白天的传输速度可能约为 1MB/秒。 它可能会变化到 5MB 或更多,具体取决于部署的发电机区域中有多少太阳能电池板。 由于太阳能发电机通常位于山区,因此有时可能会断网。 他们希望将传感器数据保存到 S3,因为那里都是只读数据。 他们还将使用 SageMaker...
1
回答
0
点赞数
54
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 在EventBridge中,我有一个Event Bus和2个规则。在Kinesis中,我有一个Data Stream。 其中一个规则的目标是CloudWatch中的一个Log Group。第二个规则的目标是我在Kinesis中的Data Stream。这个规则有一个带有策略的角色,执行我Data Stream上需要的所有操作。 当我去我的Event Bus并使用“S...
1
回答
0
点赞数
110
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 我正在关注 [AWS CloudWatch Logs - 设置新的跨账户订阅](https://docs.amazonaws.cn/en_us/AmazonCloudWatch/latest/logs/Cross-Account-Log_Subscription-New.html),参考该文档我能够从账户 A 获取 WAF 日志,并传输到账户 B 中的 OpenSear...
1
回答
0
点赞数
82
检视次数
profile picture
专家
已提问 1 年前