将AWS iot消息数据发送Kinesis Firehose Stream存向S3

这篇具有很好参考价值的文章主要介绍了将AWS iot消息数据发送Kinesis Firehose Stream存向S3。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

观看此文章之前,请先学习AWS iot的数据收集:

使用Linux SDK客户端向AWS Iot发送数据-CSDN博客

1、工作原理:

1.1 规则

规则可让您的设备与 AWS 服务进行交互。分析规则并根据物品发送的消息执行操作。您可以使用规则来支持任务,例如补充或筛选从设备接收的数据。

1.2 目的地

目的地是定义规则引擎可将数据路由至何处的资源。目的地可以跨规则重复使用,并且可能需要经过确认或配置才能使用。目的地可让规则引擎将数据发送到未与 AWS IoT 原生集成的其他服务。

2、创建消息路由

2.1 点击消息路由,并创建规则

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算

2.2 规则名称

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算

2.3 选择SQL语句

使用以下值输入 SQL 语句:SELECT <Attribute> FROM <Topic Filter> WHERE <Condition>。例如:SELECT temperature FROM 'iot/topic' WHERE temperature > 50。 要了解更多信息,请参阅 AWS IoT SQL 参考。

SELECT * FROM 'sdk/test/python'

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算

2.4 操作写入KFS

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算

2.5 创建Firehose流

源选择 Direct PUT  目标选择Amazon S3

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算

2.5 创建存储桶

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算

2.6 设置目标

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算

2.7 创建新角色

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算

至此,完成消息路由的创建

3、测试

3.1 客户端操作

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算

3.2 检查S3数据

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算

将AWS iot消息数据发送Kinesis Firehose Stream存向S3,AWS IoT,aws,云计算文章来源地址https://www.toymoban.com/news/detail-823276.html

到了这里,关于将AWS iot消息数据发送Kinesis Firehose Stream存向S3的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 树莓派 + AWS IoT Greengrass

    https://docs.amazonaws.cn/en_us/greengrass/v2/developerguide/quick-installation.html?icmpid=docs_gg_console 准备自动化安装过程中IAM需要的必要权限 https://docs.amazonaws.cn/en_us/greengrass/v2/developerguide/provision-minimal-iam-policy.html 本地用配置好的aws cli确认当前的IAM user 来到IAM控制台中先创建一个policy. 注意替

    2024年02月11日
    浏览(31)
  • AWS IoT Core 实战指南

    Amazon Web Services (AWS) 提供了全球范围内的托管服务,其中包括 AWS IoT Core,专为连接和管理物联网设备而设计。这个实战指南将带你一步步了解如何使用 AWS IoT Core 来注册设备、提高安全性、进行通信以及利用设备影子功能。 1. 创建 Thing(设备) 在 AWS IoT 控制台中,创建一个新

    2024年01月23日
    浏览(27)
  • 树莓派 + AWS IoT 入门实验

    好久没折腾过硬件了, 翻出了吃灰1年多的树莓派3B体验一下与 AWS IoT 物联网的联动, 参考官方文档: https://docs.aws.amazon.com/iot/latest/developerguide/connecting-to-existing-device.html AWS IoT 与硬件之间的通信依赖X.509证书进行加密并通过policy的策略进行限制, 所以需要先在AWS控制台做下面的准

    2024年02月02日
    浏览(29)
  • 【BUG事务内消息发送】事务内消息发送,事务还未结束,消息发送已被消费,查无数据怎么解决?

    在一个事务内完成插入操作,通过MQ异步通知其他微服务进行事件处理。 由于是在事务内发送,其他服务消费消息,查询数据时还不存在如何解决呢? 通过spring-tx包的TransactionSynchronizationManager事务管理器解决。 Rocketmq方法封装,通过TransactionSynchronizationManager.isSynchronizationAc

    2024年02月11日
    浏览(46)
  • Android APP之接入AWS IOT实现发布订阅测试

    本文中是开发的APP控制端(开发语言是Android),来接入AWS IOT平台并且实现消息的订阅和发布。由于能力有限,若有错误的理解请指正。 AWS IOT的官方文档,不得不说文档写的真“详细”啊,看得云里雾里,只能参考互联网。 由于国内使用AWS物联网平台应用不多,关于Android APP的

    2024年01月23日
    浏览(43)
  • 【雕爷学编程】Arduino智能家居之使用Nano 33 IoT和BME280传感器发送温度和湿度数据到ThingSpeak

    Arduino是一个开放源码的电子原型平台,它可以让你用简单的硬件和软件来创建各种互动的项目。Arduino的核心是一个微控制器板,它可以通过一系列的引脚来连接各种传感器、执行器、显示器等外部设备。Arduino的编程是基于C/C++语言的,你可以使用Arduino IDE(集成开发环境)来

    2024年01月25日
    浏览(33)
  • 钉钉企业机器人单聊消息发送实践-大数据平台(XSailboat)消息中心消息推送

    在笔者开发的 大数据平台XSailboat 中有 消息中心 模块,用来全平台的消息收集,整理分拆、订阅发送等功能。消息推送方式支持钉钉群聊、钉钉单聊、短信通知。现记录一下企业机器人消息单聊推送的实现过程。 这是官方的开发文档地址:《机器人发送、查询和撤回单聊消

    2024年01月25日
    浏览(34)
  • 如何将 OBJ 模型转换和压缩为 GLTF 以与 AWS IoT TwinMaker 配合使用

    推荐:使用NSDT场景编辑器快速搭建3D应用场景 在这篇博文中,引用了几种文件扩展名和模型格式。在开始之前,最好了解以下内容: OBJ – 对象文件,一种标准的 3D 图像格式,可以通过各种 3D 图像编辑程序导出和打开。 MTL – 材料库文件,包含一个或多个材料定义,每个定

    2024年02月07日
    浏览(30)
  • 微信小程序可以通过wx.request()方法发送text/event-stream请求头的数据,并通过wx.onSocketMessage()方法动态接收数据

    具体步骤如下: 1. 使用wx.request()方法发送text/event-stream请求头的数据,示例代码如下: ``` wx.request({   url: \\\'your_url\\\',   header: {     \\\'Content-Type\\\': \\\'text/event-stream\\\'   },   success: function(res) {     console.log(res)   } }) ``` 2. 在页面onLoad()方法中创建WebSocket连接,示例代码如下: ``` onLoa

    2024年02月05日
    浏览(29)
  • aws ffmpeg+ lambda来完成视频stream的截图 python 版

    准备事项: 准备一台与lambda系统相同的ec2(临时使用用完就可以delete掉了) 创建一个lambda用的layer 创建一个lambda 1.准备一台与lambda系统相同的ec2 上图是与lambda版本相同的linux系统 这台ec2是用来下载ffmpeg,解压重新压缩ffmpeg,是为lambda准备ffmpeg层的,这些任务结束后这个ec2就

    2024年02月21日
    浏览(25)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包