使用第三方技术写入数据
配置第三方技术以将 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 的权限。
部署模板
- 登录您的免费 AWS 账户并搜索 CloudFormation 服务。确保您位于要将 Lambda 部署到的 AWS 区域。
- 点击 创建 Stack。
- 在 先决条件 - 准备模板 部分,选择 模板已就绪。
- 在 指定模板 部分
- 在 模板来源 下,选择 Amazon S3 URL。
- 在 Amazon S3 URL 字段中,输入 CloudFormation 模板 URL:
https://influxdata-lambda.s3.amazonaws.com/GeoLambda.yml
- 点击 下一步。
- 在 Stack 名称 字段中输入名称。
- 输入以下 InfluxDB 详细信息
- 组织 ID
- Lambda 写入的存储桶的存储桶 ID
- 具有写入存储桶权限的令牌
- InfluxDB URL
- 不要更改或添加到任何其他字段。点击 下一步。
- 选中 我确认 AWS CloudFormation 可能会创建 IAM 资源 复选框。
- 点击 创建 Stack。
几分钟后,Stack 将部署到您的区域。要查看新的 Lambda,请选择 服务 > AWS Lambda。在 Lambda 函数页面上,您应该看到新的 Lambda。CopyZipsFunction
是助手复制函数,GeoPythonLambda
执行数据收集和写入工作

验证您的设置
GeoPythonLambda
应该根据我们设置的 AWS 规则每小时运行一次,但您应该测试并确认它是否有效。
- 点击
GeoPythonLambda
,然后点击 测试。 - 测试需要输入定义,但此 Lambda 没有输入要求,因此点击并保存默认数据集。
- 如果测试成功,则会出现绿色的 执行结果:成功 消息。
写入数据点后,当您登录 InfluxDB UI 时,您将能够探索地理位置地震数据

此页面是否对您有帮助?
感谢您的反馈!
支持和反馈
感谢您成为我们社区的一份子!我们欢迎并鼓励您提供关于 InfluxDB 和此文档的反馈和错误报告。要获得支持,请使用以下资源
拥有年度合同或支持合同的客户 可以联系 InfluxData 支持。