启用检查点操作 - Amazon Kinesis Data Analytics
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

启用检查点操作

您可以使用环境设置启用检查点。有关检查点操作的信息,请参阅容错能力中的Kinesis Data Analytics 开发者指南.

设置检查点间隔

以下 Scala 代码示例将应用程序的检查点间隔设置为 1 分钟:

// start a checkpoint every 1 minute stenv.enableCheckpointing(60000)

以下 Python 代码示例将应用程序的检查点间隔设置为 1 分钟:

st_env.get_config().get_configuration().set_string( "execution.checkpointing.interval", "1min" )

设置检查点类型

以下 Scala 代码示例将应用程序的检查点模式设置为EXACTLY_ONCE(默认值):

// set mode to exactly-once (this is the default) stenv.getCheckpointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE)

以下 Python 代码示例将您的应用程序的检查点模式设置为EXACTLY_ONCE(默认值):

st_env.get_config().get_configuration().set_string( "execution.checkpointing.mode", "EXACTLY_ONCE" )