如何触发从Azure服务总线队列到Azure Data Lake的消息？

Question

我写了C#程序，发送消息到Azure服务总线队列，这是正常工作。现在，我需要通过Azure函数将服务总线队列中收到的消息传递到数据湖，但据我所知，Azure函数不支持数据湖的绑定/触发器。是否有任何方法触发到Azure Data Lake的服务总线队列消息？提前感谢。

Answer 1

我已经成功地将数据从服务总线队列提交到数据湖，这个想法是使用webJobs，它有一个函数类，每当我们的服务总线队列接收到任何数据时就会触发该类。函数的主方法包含以下代码：

 JobHostConfiguration config = new JobHostConfiguration();
 config.UseServiceBus();
 JobHost host = new JobHost(config);
 DataLakeClass.Authentication(); // this is basically a function where my client got authenticated and further able to create csv file at data lake and append data to it.
 host.RunAndBlock();

注意：对于webjobs，您需要在Azure上创建webapp，然后创建webjobs，然后只需发布代码。有关详细帮助，您可以问更多问题。

Answer 2

可以设置Azure Functions ServiceBusTrigger并使用Azure Data Lake。NET SDK中的函数代码。请按照此处的说明使用外部Nuget包。如果逻辑应用连接器可用，使用它可能会更容易，因为这将负责使用AAD进行身份验证，而不是直接使用SDK。