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

对于新项目，我们建议您使用新的 Kinesis Data Analytics 工作室，而不是 SQL 应用程序的 Kinesis Data Analytics。Kinesis Data Analytics Studio 将易用性与高级分析功能相结合，使您能够在几分钟内构建复杂的流处理应用程序。

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

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

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

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

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

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

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

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

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

如果 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 应用程序中访问单独的应用程序内流

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

在以下示例中，首先使用 CO UNT 聚合每个源流，然后合并为一个名为的应用程序内流in_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 中生成类似于下面的输出：

其他注意事项

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