将Azure服务总线消息发送到Blob或Azure数据工厂

Question

有人能告诉我是否可以将Azure服务总线消息(特别是服务总线队列(发送到Azure数据工厂或Blob存储吗。

根据以下链接，没有用于带有ADF的服务总线的连接器。但是，它确实声明可以向Blob存储区发送消息。但不幸的是，我找不到任何关于如何将消息发送到blob存储的信息。

有人发现任何链接吗？

https://learn.microsoft.com/en-us/answers/questions/424698/suggest-solution-for-reading-data-from-azure-servi.html

Answer 1

如果您希望将Azure服务总线转变为存储Blob，这可能很容易实现。您需要一个服务总线触发器来检索消息有效负载及其ID以用作blob名称，并使用您想要的任何机制存储有效负载(消息体(。可能正在使用存储SDK将内容写入blob。或者使用随机blob名称的blob输出绑定。或者将消息ID作为blob名称。以下是一个函数示例，该函数将由服务总线队列中名为myqueue的新消息触发，并将生成一个以messages容器中消息ID命名的blob。

进程中SDK

public static class MessageTriggeredFunction
{
[FunctionName(nameof(MessageTriggeredFunction))]
public static async Task Run(
[ServiceBusTrigger("myqueue", Connection = "ServiceBusConnectionString")]string payload,
string messageId,
[Blob("messages/{messageId}.txt", FileAccess.Write, Connection = "StorageAccountConnectionString")] Stream output)
{
await output.WriteAsync(Encoding.UTF8.GetBytes(payload));
}
}

独立工作者SDK

public class MessageTriggeredFunctionIsolated
{
[Function(nameof(MessageTriggeredFunctionIsolated))]
[BlobOutput("messages/{messageId}.txt", Connection = "StorageAccountConnectionString")]
public string Run(
[ServiceBusTrigger("myqueue", Connection = "ServiceBusConnectionString")] string payload,
string messageId)
{
return payload;
}
}