Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

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

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

并行处理输入流以增加吞吐量

Amazon Kinesis Data Analytics 应用程序可以支持多个应用程序内部输入流，以将应用程序扩展到超出单个应用程序内部输入流的吞吐量。有关应用程序内部输入流的更多信息，请参阅 适用于 SQL 应用程序的 Amazon Kinesis Data Analytics：工作原理。

几乎在所有情况下，Amazon Kinesis Data Analytics 都会扩展您的应用程序，以处理馈送到您的应用程序的 Kinesis 流或 Firehose 源流的容量。但是，如果您的源流的吞吐量超出单个应用程序内部输入流的吞吐量，您可显式增加您的应用程序使用的应用程序内部输入流的数量。您需使用 InputParallelism 参数执行此操作。

如果 InputParallelism 参数大于 1，则 Amazon Kinesis Data Analytics 在应用程序内部流之间平均拆分源流的分区。例如，如果您的源流具有 50 个分片，并且您已将 InputParallelism 设置为 2，则每个应用程序内部输入流都将收到来自 25 个源流分片的输入。

当您增加应用程序内部流的数量后，您的应用程序必须显式访问每个流中的数据。有关通过代码访问多个应用程序内部流的信息，请参阅在 Amazon Kinesis Data Analytics 应用程序中访问单独的应用程序内部流。

尽管 Kinesis Data Streams 和 Firehose 流分片都以相同的方式划分到应用程序内部流，但它们在应用程序中的显示方式有所不同：

评估是否增加您的应用程序内部输入流的数量

在大多数情况下，单个应用程序内部输入流可处理单个源流的吞吐量，具体取决于输入流的复杂度和数据大小。要确定是否需要增加应用程序内输入流的数量，您可以在 Amazon CloudWatch 中监控InputBytes和MillisBehindLatest指标。

如果 InputBytes 指标大于 100 MB/秒（或您预期该指标将大于此速率），这可能会使 MillisBehindLatest 增大并导致应用程序问题的影响扩大。为解决此问题，我们建议您为应用程序选择以下语言：

如果 MillisBehindLatest 指标具有以下任一特征，则应调高您的应用程序的 InputParallelism 设置：

如果满足以下条件，您无需调高您的应用程序的 InputParallelism 设置：

有关使用的更多信息 CloudWatch，请参阅《CloudWatch 用户指南》。

实施多个应用程序内部输入流

如果应用程序是使用 CreateApplication 创建的，您可以设置应用程序内部输入流的数量。您应在使用UpdateApplication创建应用程序之后设置此数量。

设置新应用程序的输入流计数

以下示例说明了如何使用 CreateApplication API 操作将新应用程序的输入流计数设置为 2。

有关 CreateApplication 的更多信息，请参阅CreateApplication。

{
   "ApplicationCode": "<The SQL code the new application will run on the input stream>",
   "ApplicationDescription": "<A friendly description for the new application>",
   "ApplicationName": "<The name for the new application>",
   "Inputs": [ 
    { 
      "InputId": "ID for the new input stream",
      "InputParallelism": { 
        "Count": 2
    }],
   "Outputs": [ ... ],
	}]
}

设置现有应用程序的输入流计数

以下示例说明了如何使用 UpdateApplication API 操作将现有应用程序的输入流计数设置为 2。

有关 Update_Application 的更多信息，请参阅UpdateApplication。

{
   "InputUpdates": [ 
      { 
         "InputId": "yourInputId",
         "InputParallelismUpdate": { 
            "CountUpdate": 2
         }
      }
   ],
}

在 Amazon Kinesis Data Analytics 应用程序中访问单独的应用程序内部流

要使用您的应用程序中的多个应用程序内部输入流，您必须从不同的流中显式选择。以下代码示例说明了如何在创建于“入门”教程中的应用程序中查询多个输入流。

在以下示例中，每个源流在组合到名为 的单个应用程序内部流之前先通过 COUNTin_application_stream001 进行了聚合。预先聚合源流有助于确保组合的应用程序内部流可处理来自多个流的流量而不会过载。

CREATE OR REPLACE STREAM in_application_stream_001 (
    ticker VARCHAR(64),
    ticker_count INTEGER
);

CREATE OR REPLACE PUMP pump001 AS 
INSERT INTO in_application_stream_001
SELECT STREAM ticker_symbol, COUNT(ticker_symbol)
FROM source_sql_stream_001
GROUP BY STEP(source_sql_stream_001.rowtime BY INTERVAL '60' SECOND),
    ticker_symbol; 
        
CREATE OR REPLACE PUMP pump002 AS 
INSERT INTO in_application_stream_001
SELECT STREAM ticker_symbol, COUNT(ticker_symbol)
FROM source_sql_stream_002
GROUP BY STEP(source_sql_stream_002.rowtime BY INTERVAL '60' SECOND),
    ticker_symbol;
        

前面的代码示例将在 in_application_stream001 中生成类似于下面的输出：

其他注意事项

在使用多个输入流时，请注意以下事项：