--编辑--
值得一提的是,我在我的应用程序中同时使用了KCL和KPL。
只有一个碎片,您将无法将数据分离到单独的通道中。要使用这些记录,必须首先调用GetShardIterator。GetShardIterator接受流名称、碎片id和迭代器类型。
返回的碎片迭代器是指向流的指针。如果您调用GetRecords,Kinesis将返回记录,并传入碎片迭代器。响应将包含一批记录,包括数据、时间戳、序列号和分区键。
今天,在调用GetRecords/GetShardIterator时,无法指定主题或任何其他筛选器。
我有一个亚马逊运动流,由多个碎片组成。碎片的数量,因此消费者的数量,不是一个常数。 有一种不常见的事件类型,我希望广播给流中的每个消费者。 制作人是否有办法播放一张唱片,即发现碎片并将唱片放在每个碎片上?
我在推记录的时候检查过了,如果我们有2个碎片,说Shard1 我有几个问题: 如果多个出版商说两个lambda正在用一个碎片推送到一个kinesis流,这会导致任何竞争条件吗?两个不同的源是否可能推送到单个碎片 建议每个制作人使用不同的碎片,还是多个制作人使用单个碎片
我的问题是,如果出于某种原因,一些格式错误的数据被生产者放到碎片上,当Lambda函数提取它时,它会出错,然后不断地重试,会发生什么?这意味着该错误将阻止该特定碎片的处理24小时。 处理这样的应用程序错误的最佳实践是将问题包装在自定义错误中,并将此错误与所有成功处理的记录一起发送到下游,让使用者处理它吗?当然,如果出现无法恢复的错误,程序就像空指针一样崩溃,这仍然没有帮助:在接下来的24小时内,我
亚马逊云 图 1.20.2.1 - AWS AWS,即 Amazon Web Services,是亚马逊(Amazon)公司的 IaaS 和 PaaS 平台服务。AWS 提供了一整套基础设施和应用程序服务,使用户几乎能够在云中运行一切应用程序:从企业应用程序和大数据项目,到社交游戏和移动应用程序。AWS 面向用户提供包括弹性计算、存储、数据库、应用程序在内的一整套云计算服务,能够帮助企业降低 IT
我读过很多关于这方面的文章,但也有2012年或更早的文章。 (我只是打算从数据库中读取和插入一些数据。)
我想问alexa各种各样的问题,最后我想让它问“你还有什么想知道的吗?”当我说“是”(yes是工作建议)时,它应该根据我的意图来建议我。就像我在