目录
什么是 Kinesis Consumer？
Kinesis Consumer 是一项托管的、可扩展的、完全基于云的服务，允许用户每秒实时处理海量数据。它旨在允许开发人员从多个来源获取几乎任何数量的数据，所有这些数据都可以根据需要在 EC2 实例上运行的方式进行向上或向下扩展。
它用于处理来自操作日志、金融交易和社交媒体feed等来源的高容量流数据，以便获得可以触发工作流的见解。
为什么为 Amazon Kinesis Consumer 使用 Telegraf 插件？
开发人员在处理数据时面临的最重要挑战之一涉及他们每天处理的海量数据。 如果您无法发现隐藏在其中的真实故事，那么数据本身在很大程度上是没有意义的。 所有这些洞察力对于在开发过程中做出更智能、更明智的决策是必要的，但是如果您没有某种解决方案来实时释放分析能力，您就无法希望达到这一点。
Amazon Kinesis Telegraf 插件旨在精确地做到这一点，从您正在使用的各种应用程序（从您的基础设施甚至传感器）中提取所有时序数据（包括指标和事件），从而使开发人员比以往任何时候都更容易不仅创建和存储这些数据，而且实际利用它。
Amazon Kinesis Consumer 从您的应用程序、基础设施甚至传感器中提取所有时序数据（指标和事件），使您的开发人员可以轻松使用这些数据。 这些数据可用于监控您的应用程序和基础设施，以及通过在应用程序的实时仪表板中查询来增强您的应用程序 - 这是所有时序数据的单一事实来源。
此外，InfluxDB 可以处理大量写入和查询负载，不仅适用于使用 Amazon Kinesis Telegraf 插件收集的数据，还可与其他 Telegraf 插件和客户端库结合使用，以便您可以轻松访问所需的所有数据。
如何使用 Amazon Kinesis Consumer Telegraf 插件
Kinesis Consumer Telegraf 插件从 Kinesis 数据流中读取数据，并使用支持的输入数据格式之一创建指标。 这些格式将根据您正在进行的项目而有所不同。
请注意，为了使所有这些都按预期发生，需要一些 AWS Identity and Access Management (IAM) 权限。 对于 AWS Kinesis，这包括 DescribeStream、GetRecords 和 GetShardIterator 权限。 对于 Telegraf，这包括 GetItem 和 PutItem 权限。
如果您想利用存储上次处理记录的功能，可以使用以下命令创建一个表
Partition key: namespace Sort key: shard_id
使用 Amazon Kinesis Consumer Telegraf 插件的关键用例
借助 Amazon Kinesis，您可以在不同应用程序、应用程序监控、欺诈检测和实时排行榜之间流式传输数据。
关于应用程序监控，此功能是及早发现小问题的好方法，以防止它有机会在未来变成更大的问题。 通过了解应用程序的“正常”性能是什么样的，开发人员可以密切监控任何偏离该状态的情况。 然后，他们可以自行调查并根据需要进行更改，所有这些都是为了同时为消费者提供最佳性能。
欺诈检测将以类似的方式执行，查找任何和所有超出正常边界的事件。 这是在早期阶段发现欺诈的绝佳机会，同时准确了解发生了什么，并使自己处于更有利的位置以阻止它在未来再次发生。
