文档文档

使用第三方技术写入数据

配置第三方技术以将 Line Protocol 直接发送到 InfluxDB。

AWS Lambda 通过 CloudFormation 模板

使用 AWS Lambda(Amazon Web Services 的无服务器产品)写入 InfluxDB。此示例提供了一个 CloudFormation 模板,该模板每小时从 美国地质调查局 (USGS) 收集地震数据,并将其作为 Line Protocol 输出到 InfluxDB 存储桶中。

模板包含以下部分

  • 第 1-20 行:定义模板安装时要求的变量。
  • 第 21-120 行:处理 Lambda 部署的一个怪癖,即 Lambda 资产必须在部署前位于您的区域中。由于没有优雅的解决方法,这 100 行代码会在您帐户的区域中创建一个 S3 存储桶,并在其中复制这些资源。
  • 第 121-132 行:定义一个具有运行 Lambda 的基本权限的角色。
  • 第 133-144 行:定义一个 Python 库层。此层打包了 Python HTTP 库、Python S2 Geometry 库和 InfluxDB Python 客户端库。
  • 第 145-165 行:定义 Lambda 函数,这是一个压缩在名为 geo_lambda.zip 的文件中的简短 Python 脚本。
  • 第 166-188 行:定义一个事件规则,该规则具有每小时运行 Lambda 的权限。

部署模板

  1. 登录您的免费 AWS 账户并搜索 CloudFormation 服务。确保您位于要将 Lambda 部署到的 AWS 区域。
  2. 点击 创建 Stack
  3. 先决条件 - 准备模板 部分,选择 模板已就绪
  4. 指定模板 部分
  • 模板来源 下,选择 Amazon S3 URL
  • Amazon S3 URL 字段中,输入 CloudFormation 模板 URL:https://influxdata-lambda.s3.amazonaws.com/GeoLambda.yml
  1. 点击 下一步
  2. Stack 名称 字段中输入名称。
  3. 输入以下 InfluxDB 详细信息
  • 组织 ID
  • Lambda 写入的存储桶的存储桶 ID
  • 具有写入存储桶权限的令牌
  • InfluxDB URL
  1. 不要更改或添加到任何其他字段。点击 下一步
  2. 选中 我确认 AWS CloudFormation 可能会创建 IAM 资源 复选框。
  3. 点击 创建 Stack

几分钟后,Stack 将部署到您的区域。要查看新的 Lambda,请选择 服务 > AWS Lambda。在 Lambda 函数页面上,您应该看到新的 Lambda。CopyZipsFunction 是助手复制函数,GeoPythonLambda 执行数据收集和写入工作

GeoPythonLambda data in InfluxDB

验证您的设置

GeoPythonLambda 应该根据我们设置的 AWS 规则每小时运行一次,但您应该测试并确认它是否有效。

  1. 点击 GeoPythonLambda,然后点击 测试
  2. 测试需要输入定义,但此 Lambda 没有输入要求,因此点击并保存默认数据集。
  3. 如果测试成功,则会出现绿色的 执行结果:成功 消息。

写入数据点后,当您登录 InfluxDB UI 时,您将能够探索地理位置地震数据

GeoPythonLambda data in InfluxDB

此页面是否对您有帮助?

感谢您的反馈!


Flux 的未来

Flux 即将进入维护模式。您可以继续像现在这样使用它,而无需更改任何代码。

阅读更多

现已全面上市

InfluxDB 3 Core 和 Enterprise

快速启动。更快扩展。

获取更新

InfluxDB 3 Core 是一个开源、高速、最新的数据引擎,可实时收集和处理数据,并将其持久化到本地磁盘或对象存储。InfluxDB 3 Enterprise 构建在 Core 的基础上,增加了高可用性、读取副本、增强的安全性以及数据压缩功能,从而实现更快的查询和优化的存储。InfluxDB 3 Enterprise 的免费层可供非商业家庭或业余爱好者使用。

有关更多信息,请查看