Amazon Kinesis监控

免费使用此 InfluxDB 集成

什么是 Kinesis Consumer？

Kinesis Consumer 是一个托管、可扩展、完全基于云的服务，允许用户以每秒处理大量数据的方式实时处理数据。它旨在允许开发者从多个来源获取任何数量的数据，这些数据可以按需进行扩展或缩减，并且可以在 EC2 实例上运行。

它用于处理来自操作日志、金融交易和社交媒体流等来源的大量流数据，以便获得可以触发工作流程的见解。

为什么使用 Amazon Kinesis Consumer 的 Telegraf 插件？

开发者在处理数据时面临的最重要挑战之一是每天处理的数据量。如果你无法揭示隐藏在其中的真实故事，那么这些数据本身大多是无意义的。所有这些见解对于在开发过程中做出更明智和更明智的决策都是必要的，但如果没有某种解决方案可以实时解锁这种分析能力，你就不可能达到那个目标。

Amazon Kinesis Telegraf 插件正旨在做到这一点，它将来自你正在使用的各种应用程序、基础设施，甚至是传感器的所有时间序列数据（包括指标和事件）拉取进来，使开发者能够比以往任何时候都更容易地创建和存储这些数据，并将其真正地用于实际。

Amazon Kinesis Consumer 从你的应用程序、基础设施甚至传感器中拉取所有时间序列数据（指标和事件），使开发者能够轻松使用这些数据。这些数据可以用于监控应用程序和基础设施，以及通过在应用程序的实时仪表板中进行查询来增强应用程序——这是所有时间序列数据的单一来源。

此外，InfluxDB 可以处理来自 Amazon Kinesis Telegraf 插件收集的数据以及与其他 Telegraf 插件和客户端库结合的大规模写入和查询负载，使所需的所有数据都易于访问。

如何使用 Amazon Kinesis Consumer Telegraf 插件

Kinesis Consumer Telegraf 插件从 Kinesis 数据流中读取，并使用支持的输入数据格式之一创建指标。这些格式将根据你正在进行的项目的不同而有所不同。

请注意，为了使所有这些按预期发生，需要一些 AWS 身份和访问管理（IAM）权限。对于 AWS Kinesis，这包括 DescribeStream、GetRecords 和 GetShardIterator 权限。对于 Telegraf，这包括 GetItem 和 PutItem 权限。

如果你想利用存储最后处理记录的功能，可以使用以下命令创建一个表

Partition key: namespace
Sort key: shard_id

使用 Amazon Kinesis Consumer Telegraf 插件的关键用例

使用 Amazon Kinesis，你可以在不同的应用程序、应用程序监控、欺诈检测和实时排行榜之间传输数据。

就应用程序监控而言，这种功能是捕捉今天可能变成更大问题的微小问题的绝佳方式。通过了解应用程序的正常性能是什么样的，开发者可以密切监视任何偏离这种状态的情况。他们可以自行调查并做出必要的更改，所有这些都是在向消费者提供最佳性能的同时进行的。

欺诈检测将以类似的方式进行，寻找任何超出正常边界的事件。这是一个捕捉欺诈早期阶段的好机会，同时了解确切发生了什么，使自己处于更好的位置以阻止未来再次发生。

项目网址   文档