Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
同一 Kinesis 流的多个不同消费者
我有一个 Kinesis 生产者 它将单一类型的消息写入流 我想在多个完全不同的消费者应用程序中处理这个流 因此 对于给定的主题 流 具有单个发布者的发布 订阅 我还想利用检查点来确保每个消费者处理写入流的每条消息 最初 我为所有消费者和生
amazonwebservices
publishsubscribe
amazonkinesis
AWS Kinesis ShardIteratorType TRIM_HORIZON 的预期行为
Context 我不一定指的是基于 KCL 的应用程序 只是纯粹的 Kinesis API 调用 是否使用TRIM HORIZON分片迭代器类型立即为您提供流中最早发布的记录 即 Kinesis 内置 24 小时窗口内最早可用的记录 或者只
amazonwebservices
amazonkinesis
是否可以通过 CDK 为 AWS Kinesis 启用 EnableEnhancedMonitoring?
我们希望使用 CDK 记录 kinesis 的增强 每个分片 指标 对于标准指标 我们这样做 const throughput new cloudwatch GraphWidget height CHART HEIGHT width CHA
amazonwebservices
amazonkinesis
Apache Flink - 如何使用 AWS Kinesis 发送和使用 POJO
我想使用 Flink 来使用来自 Kinesis 的 POJO 是否有关于如何正确发送和反序列化消息的标准 Thanks 我用以下方法解决了它 DataStream
POJO
apacheflink
amazonkinesis
flinkstreaming
如何从 Kinesis Analytics (SQL) 中的格式化为字符串的 json 中选择数据
我有一个运动数据流 以这种格式提供数据 创建时间 时间戳 有效负载 varchar 6000 一个简化的例子payload元素 version 2 0 data whatever someString observations obs id
sql
json
amazonwebservices
amazonkinesis
Amazon Kinesis 视频 GetMedia/PutMedia
我使用 python 3 6 我想使用 API 将视频流发布到 aws kinesis 我使用 python aws 客户端创建流并GetDataEndPoint但是当我想用我的自定义请求发布我的数据时 PutMedia实际上不包含在 py
python
amazonwebservices
amazonkinesis
使用 AWS Kinesis Firehose 写入 S3 存储桶中的特定文件夹
我希望能够根据数据内的内容将数据发送到 kinesis firehose 例如 如果我发送此 JSON 数据 name John id 345 我想根据 id 过滤数据并将其发送到我的 s3 存储桶的子文件夹 例如 S3 myS3Bucke
如何从 Amazon Kinesis 流获取最新记录?
我想从 Amazon Kinesis 流中获取最新记录 我打算从该记录中提取时间戳 并将其与消费者应用程序检查点的最后一个记录的时间戳进行比较 以检查消费者是否落后 我无法使用最新的分片迭代器类型 这是因为 LATEST 指向最近的记录之后
amazonwebservices
Stream
amazonkinesis
使用 Kinesis Analytics 构建实时会话
是否有某个地方的示例 或者有人可以解释如何使用 Kinesis Analytics 构建实时会话 即会话化 这里提到这可能 https aws amazon com blogs aws amazon kinesis analytics pr
amazonkinesis
Bigdata
Kinesis lambda DynamoDB
我正在学习 AWS 服务的一个用例 在浏览完文档后 我想出了一个简单的流程 我想使用 Streams API 和 KPL 将数据提取到 Kinesis 流中 我使用示例 putRecord 方法将数据提取到流中 我正在将此 JSON 摄取到
Kinesis 分区键始终位于同一个分片中
我有一个包含 2 个分片的运动流 如下所示 StreamDescription StreamStatus ACTIVE StreamName my stream Shards ShardId shardId 000000000001 Has
amazonkinesis
AWS Lambda 性能问题
我使用与 aws lambda java 集成的 aws api gateway 但我发现这种方法存在一些严重问题 删除服务器并让您的应用程序开箱即用的概念非常好 但这是我面临的问题 我的 lambda 正在做两件简单的事情 验证从客户端接
Java
amazonwebservices
awslambda
awsapigateway
amazonkinesis
AWS CDK 中的哪个类可以选择为 Kinesis 传输流配置动态分区
我正在使用 kinesis 传输流发送流 从事件桥到 s3 存储桶 但我似乎找不到哪个类可以选择配置动态分区 这是我的交付流代码 new CfnDeliveryStream this Export delivery stream s3Des
amazons3
awscdk
amazonkinesis
amazonkinesisfirehose
通过 kinesis 触发跨账户 lambda
我试图通过帐户 A 中的 Kinesis 流触发帐户 B 中的 lambda 这与描述的类似here https aws amazon com blogs compute easy authorization of aws lambda f
amazonwebservices
awslambda
amazonkinesis
读取 Amazon Kinesis Firehose 流写入 s3 的数据
我正在将记录写入 Kinesis Firehose 流 该流最终由 Amazon Kinesis Firehose 写入 S3 文件 我的记录对象看起来像 ItemPurchase String personId String itemId
json
amazons3
amazonkinesis
amazonkinesisfirehose
如何使用 Amazon API gateway 将 json 数据放入 Kinesis 流
我使用 amazon api gateway 设置一个 API 并希望将数据放入 Kinesis 流中 Amazon API gateway 对其有内置支持 但是当我尝试放入 JSON 数据时 它给出了 序列化异常 var data ua
amazonwebservices
awsapigateway
amazonkinesis
如何构建和使用flink-connector-kinesis?
我正在尝试将 Apache Flink 与 AWS kinesis 结合使用 这document https ci apache org projects flink flink docs release 1 7 dev connector
amazonwebservices
Maven
apacheflink
amazonkinesis
connector
AWS Kinesis 中的分区键是什么?
我正在读关于AWS Kinesis 在下面的程序中 我将数据写入名为的流中TestStream 我运行这段代码 10 次 将 10 条记录插入到流中 var params Data More Sample data into the tes
nodejs
amazonwebservices
Stream
amazonkinesis
如何将kinesis视频流存储到S3存储桶中?
我正在通过 kinesis video Streaming 将实时视频流发送到亚马逊控制台 现在我想将其存储到亚马逊 S3 中 如何存储到S3请详细说明 谢谢 Amazon Kinesis Video 不会 开箱即用 地将视频存储在 S3
amazonwebservices
amazons3
Cloud
amazonkinesis
使用 Python 解析和渲染 Kinesis Video Streams 并获取输入帧的图像表示
我设置了一个管道 在其中将视频实时流式传输到 Kinesis Video Stream KVS 后者将帧发送到 Amazon Rekognition 进行人脸识别 后者进一步将它们发送到 Kinesis Data Stream KDS 最后
python
amazonwebservices
Parsing
amazonkinesis
Payload
1
2
»