Amazon Kinesis Data Analytics 文档

Amazon Kinesis Data Analytics旨在实时分析流数据。使用模板和内置运算符，您可以构建查询和实时流处理应用程序。Amazon Kinesis Data Analytics旨在设置相关资源运行您的应用程序，并且可以自动扩展以处理任何传入的数据量。  

无服务器 

您无需设置和管理复杂的基础设置就可以实现高可用性和安全处理。Amazon Kinesis Data Analytics无服务器，旨在处理连续运行您的应用程序所需的一切工作。其中包括自动预置基础设置以连续处理流数据。   

处理延迟 

Amazon Kinesis Data Analytics旨在实现亚秒级处理延迟，因此您可以生成实时警报、控制面板和可指导行动的见解。  

针对使用Apache Flink构建复杂的应用程序 

开源 

Amazon Kinesis Data Analytics旨在包括开源库，例如，Apache Flink、Apache Beam、Apache Zeppelin、Amazon SDK和亚马逊云科技服务集成。  

灵活的API 

Java、Scala、Python和SQL提供了灵活的API，专门用于不同的用例，包括有状态流处理、流式ETL和实时分析。预置的运算符和分析功能可帮助您构建Apache Flink流式应用程序。Amazon Kinesis Data Analytics可帮助您为各种使用案例执行实时处理。    

与亚马逊云科技服务集成  

您可以使用Amazon Kinesis Data Analytics 库与其他亚马逊云科技服务集成。  

高级集成功能 

除了亚马逊云科技集成外，Amazon Kinesis Data Analytics库还包括Apache Flink连接器，且具备构建自定义集成的能力。再多写几行代码，就可以修改每个集成与高级功能的操作方式。此外，您还可以使用一组Apache Flink基元构建自定义集成，帮助您读取和编写文件、目录、套接字或您可以通过互联网访问的其他资源。    

一次处理 

您可以使用Amazon Kinesis Data Analytics中的Apache Flink构建应用程序，其处理记录只准确地影响结果一次，也被称作准确地一次处理。这意味着，即使在应用程序出现中断的情况下，例如内部服务维修或用户发起的应用程序更新，服务旨在确保所有数据得到处理，并且没有重复数据。   

状态处理 

服务可以将之前的和正在处理的计算或状态存储在运行的应用程序存储中。这确保您在任何时间段比较实时结果和之前的结果，并且在应用程序中断期间快速恢复。状态旨在是加密的，并且以增量方式保存在运行应用程序存储中。   

持久应用程序备份 

服务旨在让您可以通过API调用创建和删除应用程序备份。在出现中断后，您可以从最新备份恢复应用程序，或者您可以将应用程序恢复到之前的版本。  

Amazon Kinesis Data Analytics Studio 

流处理检查和可视化 

Kinesis Data Analytics Studio旨在通过内置的可视化功能支持亚秒级查询。您可以执行临时查询以快速检查数据流，并在几秒钟内查看结果。  

简单的构建和运行环境 

Studio Notebook旨在为开发、调试代码和运行流处理应用程序提供单界面开发体验。  

使用SQL、Python或Scala处理 

Kinesis Data Analytics Studio旨在同一开发环境中支持SQL、Python和Scala。Syntax突出显示、验证和上下文相关建议可引导您在笔记本中使用对Apache Flink特定功能的内置支持与数据进行交互。   

流处理应用程序的无服务器快速开发  

Kinesis Data Analytics Studio旨在无需服务器用于预置、管理或扩展，只需编写代码，然后为应用程序使用的资源付费。您可将笔记本中的代码部署到具有自动扩展和持久状态的持续运行的流处理应用程序中。   

开源 

Kinesis Data Analytics Studio在Apache Flink应用程序和Apache Zeppelin上运行并生成应用程序的生产环境。 

Kinesis Data Analytics SQL应用程序 

对于新项目，我们建议您使用新的Kinesis Data Analytics Studio，而不是r Kinesis Data Analytics for SQL Applications。Kinesis Data Analytics Studio旨在将易用性与高级分析功能相结合，帮助您构建复杂的流处理应用程序。  

支持标准SQL 

Amazon Kinesis Data Analytics支持标准ANSI SQL。 

集成输入和输出 

Amazon Kinesis Data Analytics旨在集成了Amazon Kinesis Data Streams和Amazon Kinesis Data Firehose，因此您可以在输入流指向Amazon Kinesis Data Analytics提取流数据。您可以通过Amazon Kinesis Data Firehose将处理结果发送到其他亚马逊云科技服务。您还可以将输出数据发送到Amazon Kinesis Data Streams，以构建高级流处理管道。  

基于控制台的SQL编辑器 

该服务旨在提供一个基于控制台的编辑器，使用流数据操作（例如，滑动时间窗口均值）构建SQL查询。您还可以使用实时数据查看流结果和错误，交互调试或进一步优化您的脚本。  

架构编辑器 

Amazon Kinesis Data Analytics旨在提供简单易用的架构编辑器，以探索和编辑输入数据的结构。向导旨在识别标准数据格式（例如，JSON和CSV），并推断输入数据的结构，以创建基准架构，以便于您使用架构编辑器进一步优化。  

预构建的SQL模板 

交互SQL编辑器自带一系列SQL模板，提供适用于大部分常见操作类型的基准SQL代码（例如，集合、按事件转换和过滤）。您可以选择适合您的分析任务的模板，然后编辑使用SQL编辑器提供的代码，为您的具体使用案例进行自定义。   

高级流处理功能 

Amazon Kinesis Data Analytics旨在提供针对流处理的功能，因此您可以轻松执行高级分析（例如，对流数据进行异常检测和top-K分析）。  

其他信息 

有关服务控制、安全特性及功能的其他信息，包括有关存储、检索、修改、限制和删除数据的信息，请参见 https://docs.amazonaws.cn/。以上链接包含的信息不构成光环新网关于亚马逊云科技（北京区域）的客户协议或西云数据关于亚马逊云科技（宁夏区域）的客户协议的“文档”的一部分，也不构成您与光环新网或西云数据之间就您使用亚马逊云科技中国区域服务达成的其他协议的任何部分。