当前位置: 首页 > 知识库问答 >
问题:

亚马逊KCL检查点和修剪地平线

简培
2023-03-14

在AWS KCL库中,检查点和修剪是如何相关的?

处理启动、关机和节流的文档页面表示:

第一页似乎表示KCL在流的顶端恢复,第二页在最后一个已知处理的记录(该记录被标记为由recordprocessor使用checkpointer处理)恢复。在我的情况下,我肯定需要在最后一个已知处理过的记录处重新启动。是否需要将initialPositionInStream设置为Trim_Horizon?

共有1个答案

濮景龙
2023-03-14

使用kinesis stream,您有两种选择,您可以读取最新的记录,或者从最早的记录开始(TRIM_HORIZON)。

但是,一旦启动应用程序,它就会从停止使用检查点的位置读取。您可以在dynamodb中看到这些检查点(通常表名作为应用程序名)。因此,如果你重新启动你的应用程序,它通常会从停止的地方继续。

答案是否定的,您不需要将initialPositionInStream设置为trim_horizon。

 类似资料:
  • 我刚刚开始使用AWS EC2。我明白EC2就像一台远程计算机,在那里我可以做几乎所有我想做的事情。然后我发现了ECS的事。我知道它使用Docker,但我对这两者之间的关系感到困惑。 ECS只是EC2中的Docker安装吗?如果我已经有一个EC2并且我启动了一个ECS,这是否意味着我有两个实例?

  • 亚马逊云 图 1.20.2.1 - AWS AWS,即 Amazon Web Services,是亚马逊(Amazon)公司的 IaaS 和 PaaS 平台服务。AWS 提供了一整套基础设施和应用程序服务,使用户几乎能够在云中运行一切应用程序:从企业应用程序和大数据项目,到社交游戏和移动应用程序。AWS 面向用户提供包括弹性计算、存储、数据库、应用程序在内的一整套云计算服务,能够帮助企业降低 IT

  • 我想问alexa各种各样的问题,最后我想让它问“你还有什么想知道的吗?”当我说“是”(yes是工作建议)时,它应该根据我的意图来建议我。就像我在

  • 但有些多重问题, 如何在.NET中对Amazon Cognito用户池执行身份验证。我以以下方式启动Auth: 他们的文档非常非常糟糕,当我想回应挑战时,我似乎找不到该通过什么。 我假设它只是用默认的JWT中间件配置OWIN,还是应该期待其他东西?

  • 我们正在开发一个系统,我们需要向数千部手机发送推送通知。我们使用Amazon SNS进行了设置。我们将向每部手机发送单独的消息,因此我们直接发送到SNSendpointARN,而不是主题ARN。 我们目前正在想这个系统的性能。我在网上找不到任何关于可以向SNS发送多少消息的内容。例如,如果我需要向25000个SNSendpoint发送25000条消息,我可以以多快的速度发送它们?秒、分钟、小时?

  • 我正在努力培养Alexa技能。我仍在试图让Alexa在有意向请求时说些什么,但我遇到了一个错误,我不知道该怎么办。当我通过Alexa服务模拟器运行示例话语时,我得到了错误: 无法调用远程终结点,或者它返回的响应无效。 如果我在lambda测试事件中运行相同的语句,我得到的错误是: "错误消息":"异常:引用错误:未定义输出" 我的javascript代码是 任何帮助将不胜感激,谢谢!