InputUpdate - 适用于 SQL 应用程序的 Amazon Kinesis Data Analytics 开发人员指南
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

对于新项目,建议您使用新的适用于 Apache Flink Studio 的托管服务,而不是使用适用于 SQL 应用程序的 Kinesis Data Analytics。Managed Service for Apache Flink Studio 不仅操作简单,还具有高级分析功能,使您能够在几分钟内构建复杂的流处理应用程序。

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

InputUpdate

描述特定输入配置 (由应用程序 InputId 标识) 的更新。

目录

InputId

要更新的应用程序输入的输入 ID。

类型:字符串

长度限制:最小长度为 1。长度上限为 50。

模式:[a-zA-Z0-9_.-]+

必需:是

InputParallelismUpdate

描述并行度更新 (Amazon Kinesis Analytics 为特定流式传输源创建的应用程序内部流的数量)。

类型:InputParallelismUpdate 对象

必需:否

InputProcessingConfigurationUpdate

描述输入处理配置的更新。

类型:InputProcessingConfigurationUpdate 对象

必需:否

InputSchemaUpdate

描述流式传输源中的数据格式,以及流式传输源上的每个记录元素映射到所创建应用程序内部流中相应列的方式。

类型:InputSchemaUpdate 对象

必需:否

KinesisFirehoseInputUpdate

如果 Amazon Kinesis Firehose 传输流是要更新的流式传输源,则会提供更新的流 ARN 和 IAM 角色 ARN。

类型:KinesisFirehoseInputUpdate 对象

必需:否

KinesisStreamsInputUpdate

如果 Amazon Kinesis 流是要更新的流式传输源,则提供更新的流的 Amazon 资源名称 (ARN) 和 IAM 角色 ARN。

类型:KinesisStreamsInputUpdate 对象

必需:否

NamePrefixUpdate

Amazon Kinesis Analytics 为特定流式传输源创建的应用程序内部流的名称前缀。

类型:字符串

长度限制:最小长度为 1。最大长度为 32。

必需:否

另请参阅

有关在特定语言的 Amazon 软件开发工具包中使用此 API 的更多信息,请参阅以下内容: