经过仔细考虑，我们决定停用适用于 SQL 应用程序的 Amazon Kinesis Data Analytics： 1. 从 **2025年9月1日起，**我们将不再为适用于SQL应用程序的Amazon Kinesis Data Analytics Data Analytics提供任何错误修复，因为鉴于即将停产，我们对其的支持将有限。 2. 从 **2025 年 10 月 15 日**起，您将无法为 SQL 应用程序创建新的 Kinesis Data Analytics。 3. 从 **2026 年 1 月 27 日**起，我们将删除您的应用程序。您将无法启动或操作 Amazon Kinesis Data Analytics for SQL 应用程序。从那时起，将不再提供对 Amazon Kinesis Data Analytics for SQL 的支持。有关更多信息，请参阅 [Amazon Kinesis Data Analytics for SQL 应用程序停用](discontinuation.md)。本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。 # DiscoverInputSchema **注意** 本文档适用于 Amazon Kinesis Data Analytics API 版本 1，该版本仅支持 SQL 应用程序。版本 2 的 API 支持 SQL 和 Java 应用程序。有关版本 2 的更多信息，请参阅 [Amazon Kinesis Data Analytics API V2 文档](/kinesisanalytics/latest/apiv2/Welcome.html)。通过评估指定流式传输源 (Amazon Kinesis 流或 Amazon Kinesis Firehose 传输流) 或 S3 对象上的示例记录，推断架构。在响应中，该操作返回推断的架构以及该操作用于推断架构的示例记录。在为应用程序配置流式传输来源时，您可以使用此推断的架构。有关概念信息，请参阅[配置应用程序输入](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html)。注意：使用 Amazon Kinesis Analytics 控制台创建应用程序时，控制台使用此操作来推断架构并将其显示在控制台用户界面中。此操作需要执行 `kinesisanalytics:DiscoverInputSchema` 操作的权限。 ## 请求语法 ``` { "InputProcessingConfiguration": { "InputLambdaProcessor": { "ResourceARN": "string", "RoleARN": "string" } }, "InputStartingPositionConfiguration": { "InputStartingPosition": "string" }, "ResourceARN": "string", "RoleARN": "string", "S3Configuration": { "BucketARN": "string", "FileKey": "string", "RoleARN": "string" } } ``` ## 请求参数请求接受采用 JSON 格式的以下数据。 ** [InputProcessingConfiguration](#API_DiscoverInputSchema_RequestSyntax) ** [InputProcessingConfiguration](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/API_InputProcessingConfiguration.html) 用于在发现记录架构之前对记录进行预处理。类型：[InputProcessingConfiguration](API_InputProcessingConfiguration.md) 对象必需：否 ** [InputStartingPositionConfiguration](#API_DiscoverInputSchema_RequestSyntax) ** 您希望 Amazon Kinesis Analytics 根据指定流式传输源发现目的开始读取记录的时刻。类型：[InputStartingPositionConfiguration](API_InputStartingPositionConfiguration.md) 对象必需：否 ** [ResourceARN](#API_DiscoverInputSchema_RequestSyntax) ** 流式传输来源的 Amazon 资源名称（ARN）。类型：字符串长度限制：最小长度为 1。最大长度为 2048。模式：`arn:.*` 必需：否 ** [RoleARN](#API_DiscoverInputSchema_RequestSyntax) ** 可由 Amazon Kinesis Analytics 代入以代表您访问流的 IAM 角色的 ARN。类型：字符串长度限制：最小长度为 1。最大长度为 2048。模式：`arn:.*` 必需：否 ** [S3Configuration](#API_DiscoverInputSchema_RequestSyntax) ** 指定此参数可从 Amazon S3 对象中的数据发现架构。类型：[S3Configuration](API_S3Configuration.md) 对象必需：否 ## 响应语法 ``` { "InputSchema": { "RecordColumns": [ { "Mapping": "string", "Name": "string", "SqlType": "string" } ], "RecordEncoding": "string", "RecordFormat": { "MappingParameters": { "CSVMappingParameters": { "RecordColumnDelimiter": "string", "RecordRowDelimiter": "string" }, "JSONMappingParameters": { "RecordRowPath": "string" } }, "RecordFormatType": "string" } }, "ParsedInputRecords": [ [ "string" ] ], "ProcessedInputRecords": [ "string" ], "RawInputRecords": [ "string" ] } ``` ## 响应元素如果此操作成功，则该服务将会发送回 HTTP 200 响应。服务以 JSON 格式返回以下数据。 ** [InputSchema](#API_DiscoverInputSchema_ResponseSyntax) ** 从流式传输来源推断出的架构。它识别流式传输来源中数据的格式，以及每个数据元素如何映射到在应用程序内部流中创建的相应列。类型：[SourceSchema](API_SourceSchema.md) 对象 ** [ParsedInputRecords](#API_DiscoverInputSchema_ResponseSyntax) ** 一个元素数组，其中每个元素对应于流记录中的一行（流记录可以有多行）。类型：字符串数组的数组。 ** [ProcessedInputRecords](#API_DiscoverInputSchema_ResponseSyntax) ** 由 `InputProcessingConfiguration` 参数中指定的处理器修改的流数据。类型：字符串数组 ** [RawInputRecords](#API_DiscoverInputSchema_ResponseSyntax) ** 为推断架构而采样的原始流数据。类型：字符串数组 ## 错误 ** InvalidArgumentException ** 指定的输入参数值无效。 ** message ** HTTP 状态代码：400 ** ResourceProvisionedThroughputExceededException ** 由于亚马逊 Kinesis Streams 的缘故，Dis ProvisionedThroughputExceededException covery 未能从直播来源获得记录。有关更多信息，请参阅[GetRecords](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html)《亚马逊 Kinesis Streams API 参考》。 HTTP 状态代码：400 ** ServiceUnavailableException ** 该服务不可用。退后一步，重试该操作。 HTTP 状态代码：500 ** UnableToDetectSchemaException ** 数据格式无效。Amazon Kinesis Analytics 无法检测给定流式传输源的架构。 HTTP 状态代码：400 ** UnsupportedOperationException ** 由于不支持指定的参数或指定的资源对此操作无效，请求被拒绝。 HTTP 状态代码：400 ## 另请参阅有关以特定语言之一使用此 API 的更多信息 AWS SDKs，请参阅以下内容： + [AWS 命令行界面 V2](https://docs.aws.amazon.com/goto/cli2/kinesisanalytics-2015-08-14/DiscoverInputSchema) + [AWS 适用于.NET 的 SDK V4](https://docs.aws.amazon.com/goto/DotNetSDKV4/kinesisanalytics-2015-08-14/DiscoverInputSchema) + [AWS 适用于 C\$1\$1 的 SDK](https://docs.aws.amazon.com/goto/SdkForCpp/kinesisanalytics-2015-08-14/DiscoverInputSchema) + [AWS 适用于 Go v2 的 SDK](https://docs.aws.amazon.com/goto/SdkForGoV2/kinesisanalytics-2015-08-14/DiscoverInputSchema) + [AWS 适用于 Java 的 SDK V2](https://docs.aws.amazon.com/goto/SdkForJavaV2/kinesisanalytics-2015-08-14/DiscoverInputSchema) + [AWS JavaScript V3 版软件开发工具包](https://docs.aws.amazon.com/goto/SdkForJavaScriptV3/kinesisanalytics-2015-08-14/DiscoverInputSchema) + [AWS 适用于 Kotlin 的 SDK](https://docs.aws.amazon.com/goto/SdkForKotlin/kinesisanalytics-2015-08-14/DiscoverInputSchema) + [AWS 适用于 PHP 的 SDK V3](https://docs.aws.amazon.com/goto/SdkForPHPV3/kinesisanalytics-2015-08-14/DiscoverInputSchema) + [AWS Python 软件开发工具包](https://docs.aws.amazon.com/goto/boto3/kinesisanalytics-2015-08-14/DiscoverInputSchema) + [AWS 适用于 Ruby V3 的 SDK](https://docs.aws.amazon.com/goto/SdkForRubyV3/kinesisanalytics-2015-08-14/DiscoverInputSchema)