AddApplicationOutput - Amazon Managed Servics for Apache Flink(前身为 Amazon Kinesis Data Analytics for Apache Flink)

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

AddApplicationOutput

向基于 SQL 的 Kinesis Data Analytics 应用程序添加外部目标。

如果您希望 Kinesis Data Analytics 将数据从应用程序中的应用程序内部流传递到外部目标(例如 Kinesis 数据流、Kinesis Data Firehose 传输流或 Amazon Lambda 函数),则可以使用此操作将相关配置添加到您的应用程序。您可以为您的应用程序配置一个或多个输出。每个输出配置都映射一个应用程序内部流和一个外部目标。

您可以使用其中一个输出配置将数据从应用程序内的错误流传输到外部目标,以便您分析错误。

任何配置更新(包括使用此操作添加流式传输源)都会生成新版本的应用程序。您可以使用 DescribeApplication 操作来找到当前的应用程序版本。

请求语法

{ "ApplicationName": "string", "CurrentApplicationVersionId": number, "Output": { "DestinationSchema": { "RecordFormatType": "string" }, "KinesisFirehoseOutput": { "ResourceARN": "string" }, "KinesisStreamsOutput": { "ResourceARN": "string" }, "LambdaOutput": { "ResourceARN": "string" }, "Name": "string" } }

请求参数

请求接受采用 JSON 格式的以下数据。

ApplicationName

要将输出配置添加到的应用程序的名称。

类型:字符串

长度限制:长度下限为 1。长度上限为 128。

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

必需:是

CurrentApplicationVersionId

要向其添加输出配置的应用程序的版本。您可以使用 DescribeApplication 操作来获取当前的应用程序版本。如果指定的版本不是当前版本,则返回 ConcurrentModificationException

类型:长整型

有效范围:最小值为 1。最大值为 999999999。

必需:是

Output

对象的数组,每个对象描述一项输出配置。在输出配置中,指定应用程序内部流的名称、目标(即 Kinesis 数据流、Kinesis Data Firehose 传输流或 Amazon Lambda 函数),并记录在写入该目标时要使用的格式。

类型:Output 对象

必需:是

响应语法

{ "ApplicationARN": "string", "ApplicationVersionId": number, "OutputDescriptions": [ { "DestinationSchema": { "RecordFormatType": "string" }, "KinesisFirehoseOutputDescription": { "ResourceARN": "string", "RoleARN": "string" }, "KinesisStreamsOutputDescription": { "ResourceARN": "string", "RoleARN": "string" }, "LambdaOutputDescription": { "ResourceARN": "string", "RoleARN": "string" }, "Name": "string", "OutputId": "string" } ] }

响应元素

如果此操作成功,则该服务将会发送回 HTTP 200 响应。

服务以 JSON 格式返回以下数据。

ApplicationARN

应用程序 Amazon 资源名称 (ARN)。

类型:字符串

长度限制:最小长度为 0。最大长度为 2048。

模式:arn:.*

ApplicationVersionId

更新的应用程序版本 ID。应用程序更新时,Kinesis Data Analytics 会增加此 ID。

类型:长整型

有效范围:最小值为 1。最大值为 999999999。

OutputDescriptions

描述应用程序输出配置。有关更多信息,请参阅配置应用程序输出

类型:OutputDescription 对象数组

错误

ConcurrentModificationException

由于对应用程序进行并发修改而引发的异常。此错误可能是由于在未使用当前应用程序 ID 的情况下尝试修改应用程序所致。

HTTP 状态代码:400

InvalidArgumentException

指定的输入参数值无效。

HTTP 状态代码:400

InvalidRequestException

操作的请求 JSON 无效。

HTTP 状态代码:400

ResourceInUseException

该应用程序不可用于此操作。

HTTP 状态代码:400

ResourceNotFoundException

无法找到指定的应用程序。

HTTP 状态代码:400

另请参阅

有关在特定语言的 AWS SDK 中使用此 API 的更多信息,请参阅以下内容: