-
连接Kinesis生产商AWS Kinesis 443时出错
无法打开与Monitoring.us-east-1.amazonaws.com:443的连接:连接到AWS kinesis时证书验证失败 <pre><code>public static -
如何配置Lambda在AWS Kinesis流中发送Avro数据
我需要将avro格式的数据发送到kinesis流。我尝试使用put_record或put_records推送记录,但只期望字节或ByteArray -
AWS Kinesis Firehose将记录大小四舍五入为5KB!为什么?
<ul> <li> 我对AWS Kinesis Firehose的理解是,它旨在消除人们编写逻辑以将数据批量发送到其他服务的需求。 -
使用KCL时,Kinesis Consumer需要哪些IAM权限?
我有一个使用Kinesis Client Library(KCL)编写的Kinesis使用者。该使用者正在以假定的IAM角色运行。 我 -
在Apache Flink的protobuf事件中发布反序列化事件
我正在flink应用中读取运动学的事件。事件采用protobuf格式。如果我在flink应用程序中使用<code>'com.googl -
使用Docker容器的KCL实施
我有一个用例,其中有一个现有的Kinesis流,但我不知道有多少个分片。但是,我必须创建一个将要从碎 -
将PutRecords直接发布到kinesis API,而无需(真实)身份验证
我想通过https API将来自移动应用程序的PutRecords请求直接发送到AWS Kinesis数据流中。我不想使用API网 -
AWS Firehose分析不发布新数据
我有一个连接到aws firehose的运动分析,并且在最初的几分钟内它发布数据,但是过了一段时间,它仍然 -
如何使用W3C_LOG_PARSE分析kinesis代理发送的日志?
我使用kinesis代理通过简单的配置将Apache Log发送到kinesis数据流。 <pre><code>{ "kinesis.endpoint":  -
Dynamodb表上的汇总统计
我有一个DynamoDB表,每天接收约1500万个浏览记录,例如: <pre><code>{"domain": "google.com", " -
Kinesis + Storm |如何从拓扑获取最新事件?
我是apache风暴的新手。在Java中创建了一个风暴项目,该项目成功在prod nimbus上运行。 我需要检查S -
什么是单调列?
我已经在<a href="https://docs.aws.amazon.com/kinesisanalytics/latest/sqlref/sql-reference-monotonic-expressions-operators.html" rel=" -
无法为Kinesis Consumer覆盖DynamoDB端点
无法通过aws-sdk,localstack和aws-kcl设置本地环境。创建使用者并尝试在我的本地环境上运行它后,我收到 -
Kinesis Analytics编写用户定义的函数
对于UDF(<a href="https://docs.aws.amazon.com/kinesisanalytics/latest/sqlref/sql-reference-create-function.html" rel="nofollow norefer -
防范BigQuery垃圾邮件
我具有以下软件组件: <ul> <li> Amazon Kinesis事件流 <ul> <li>事件表示例:<code>product-purchase-events</code> </ -
使用localstack Kinesis运行KCL使用者时出错
在同步Kinesis分片和租约时捕获到异常 由于:io.netty.handler.codec.http2.Http2Exception:第一个接收到的帧 -
如何使用GetRecordsRequest从AWS Kinesis获取数据?
我找到了一种将实时虚拟数据发送到AWS Kinesis的方法,我需要如何使用GetRecordsRequest从AWS Kinesis接收数据 -
Firehose,管道,数据流的Kinesis服务有何区别/用例
我对不同的Kinesis服务感到困惑,我已阅读以下术语: <pre><code>Kinesis streaming data platform Kinesis Data Strea -
Kinesis分片读取限制为2 mib,那么get记录调用最多可以达到10 mib的可能性
我指的是这个<a href="https://docs.aws.amazon.com/streams/latest/dev/service-sizes-and-limits.html" rel="nofollow noreferrer">docume -
Amazon Timestream用于事件来源
谁知道Amazon的新Timestream db对于在AWS中构建的事件源系统来说是否是合理的事件日志存储?我看不到有关 -
带有Kinesis Event Consumer的AWS CloudFormation模板
我试图创建一个Lambda,当Kinesis Stream中有记录时将调用该Lambda。为此,在lambda的template.yaml中,我通过以 -
Kinesis Analytics翻滚窗口可将常见事件分组在一起
我有一个用例,其中Kinesis正在从视频流中提取事件(每个视频流具有唯一的ID),但是数据破裂了,并 -
使用sudo的Gstreamer管道将Kinesis实时流作为python子进程:“无此类元素或插件'kvssink'”
我已经测试了<a href="https://docs.aws.amazon.com/kinesisvideostreams/latest/dg/examples-gstreamer-plugin.html" rel="nofollow norefe -
无法使用Spring Cloud Kinesis Stream启动Spring Boot
Spring启动应用程序在启动期间失败。看起来像是依赖项问题,但无法找出缺少的内容。 pom.xml -
如何保持Flink运动消费者的幂等性?
我有一个用例,其中,我通过EMR上运行的flink作业(使用flink-kinesis连接器)使用了kinesis流中的事件。作 -
如何暂停消费者在Spring Cloud Kinesis流中使用消息
我正在寻找一种解决方案,以在下游服务关闭时暂停应用程序本身的运动流中的消息消费。我正在使用sp -
software.amazon.kinesis和com.amazonaws有什么区别?
我正在尝试创建一个从Kinesis数据流读取的应用程序。 MVN存储库包含<strong> software.amazon.kinesis:amazon-kinesi -
如何使用Terraform + / Cloudformation连接AWS Database Migration Service和Kinesis数据流?
我正在尝试将本地SQL Server 2016 Enterprise Edition实例中的数据获取到云中。我遇到了障碍,所以如果有人对 -
如何延迟处理AWS Kinesis消息?
我想将来自AWS Kinesis流的消息处理延迟一小时。我已将KCL使用者配置为每四分钟读取一批记录,检查每条 -
从对象转换为AWS Kinesis-> Java无法从VALUE_NUMBER_FLOAT令牌
我正在研究AWS lambda函数,以便动态获取SNS事件或Kinesis事件,为此,在lambda函数中,我将Object作为参数: