使用Azure功能将遥测消息从Azure IoT中心路由到Data Lake存储
如何使用AZURE函数将遥测消息从Azure IOT中心路由到Data Lake存储。
共有1个答案
听起来您想使用Azure功能和IoT Hub触发器来处理消息并传输到Data Lake Store。
有一个官方博客如何将Azure函数与IoT Hub消息路由一起使用介绍如何使用IoT Hub消息路由设置Azure函数和现有SO线程Azure函数-如何为我的IoTHub消息设置IoTHubTrigger？你可以参考一下。
然后，您只需要处理来自IoTHub的消息，并使用数据湖存储SDK（例如使用。NET）转移到Data Lake Store。
此外，在一些简单的案例中使用Azure Stream Analytics也是一个简单的解决方案
-
我正在考虑将Socket.io集成到一个express应用程序中。 js有一个非常好的特性，可以通过socket.io消息调用快速路由。 不过，帆在其他方面比我需要的要多一点。我正在寻找一种方法，使socket.io请求转发到快速路由，而不必使用整个sails框架。我想这是一个很常见的需求，所以我很惊讶我没有找到一个npm模块来做这件事，但是找了很长时间，我什么也没有找到。Express.io会这
-
我想通过运行在Azure VM上的FTP服务器与用户共享Azure Blob存储中的文件。 据我所知，您不能在VM上挂载Blob存储，但可以使用“网络使用”挂载Azure文件共享。 Blob存储上的文件将以增量方式上载，因此理想情况下，我希望在上载时将其复制到Azure文件，Azure功能似乎是理想的方式，因为它们很容易为我设置和处理Blob存储上的触发器。 我如何使用Azure功能将文件从Blo
-
我希望编写一个Azure函数，该函数接收来自IoTHub的消息，并根据消息中的数据将其放置在服务总线队列中。问题是，队列名称将根据我所查看的消息和留档的参数进行更改，例如，将队列名称设置为输出设置的一部分。有人做过类似的事情吗？或者有任何代码示例可以根据传入消息中的值写入队列？我试图设置一个函数，但它甚至不让我设置输出类型为服务总线，而不把队列名称，我不能，因为它是不固定的！ 所以如果输入是： 函
-
在RabbitMQ中，可以创建一个交换，然后将其绑定到多个队列，每个队列都有一个路由密钥。这使得消息传递体系结构如下所示： 客户端将消息发布到exchange中，该exchange只将路由密钥为“foo”的消息路由到队列，只将路由密钥为“bar”的消息路由到队列，所有消息都路由到队列。 我很难弄清楚如何在AWS中做到这一点。我首先想到的是在各个队列上设置权限,以接受基于主题的消息,但权限条件的唯一
-
它像发布/订阅一样工作。因此，可以将队列绑定或取消绑定到不同的事件，以便消费者/订阅者只接收他们感兴趣的消息。 当然，生产者/发布者现在使用绑定键（事件名）作为将其传递给pika实现。但是，当它为不存在的绑定发布某些内容时，消息就会丢失，也就是说，当没有人为事件绑定队列时，但是一些发布服务器调用。 所以我的问题是： > 检查pika.basic_publish的返回值。它总是返回。 检查当我们试图
-
我正在使用ActiveMQ Artemis 2.17.0，并且面临路由问题。 我实现了一个插件，它记录了before消息路由，我看到一些消息从路由到。 没有转移设置，主题和队列由生产者和消费者动态创建。有一个将目标映射到虚拟主题的设置 和都是有效的主题，但它们不应该被链接。 什么能解释这种行为？