Azure Logic Apps Standard中Service Bus会话消息获取失败问题求助

问题根源 #

你推测的结论是对的：Get messages from a queue session 动作必须在由会话感知触发器（如On single new message from queue session）启动的工作流上下文中使用，因为该动作依赖触发器已经绑定的会话连接。而你的RunBre是HTTP触发的，没有会话上下文绑定，所以会抛出会话未找到的错误。

可行解决方案 #

方案1：改用普通Receive message动作指定会话ID

Azure Service Bus连接器提供了不依赖会话上下文的Receive message动作，可通过参数指定会话ID来接收目标消息：

• 移除RunBre中的Get messages from a queue session动作，添加Receive message（Azure Service Bus连接器下的动作）。
• 配置队列名称后，展开高级选项，在Session Id字段填入你生成的会话ID变量。
• 设置Max wait time（例如30秒），确保有足够时长等待StubSatellite返回响应。
• 若响应队列可能存在多条同会话ID的消息，可添加循环逻辑，直到接收到目标响应消息；或使用PeekLock模式，处理完成后手动完成消息。

方案2：通过内联代码调用Service Bus SDK接收会话消息

如果连接器动作无法满足需求，可利用Logic Apps Standard的内联代码功能，直接调用Service Bus SDK实现会话消息接收：

using Azure.Messaging.ServiceBus;

public static async Task<object> Run(dynamic input, ILogger log)
{
    // 从环境变量读取Service Bus连接字符串（避免硬编码）
    string connectionString = Environment.GetEnvironmentVariable("ServiceBus_ConnectionString");
    string responseQueueName = "your-response-queue-name";
    string targetSessionId = input.SessionId;

    await using var serviceBusClient = new ServiceBusClient(connectionString);
    // 接受指定会话的连接
    var sessionReceiver = await serviceBusClient.AcceptSessionAsync(responseQueueName, targetSessionId);
    
    // 等待接收消息，超时时间设为30秒
    ServiceBusReceivedMessage receivedMsg = await sessionReceiver.ReceiveMessageAsync(TimeSpan.FromSeconds(30));
    if (receivedMsg != null)
    {
        // 处理完成后标记消息为已完成
        await sessionReceiver.CompleteMessageAsync(receivedMsg);
        return new { MessageContent = receivedMsg.Body.ToString() };
    }
    return null;
}

• 在RunBre工作流中添加Execute inline code动作，选择C#语言。
• 填入上述代码，替换队列名称，将会话ID作为输入参数传入。
• 在Logic Apps的配置中添加环境变量ServiceBus_ConnectionString，存储你的Service Bus连接字符串。

方案3：优化流程关联逻辑

如果允许调整流程设计，可强化消息关联规则：

• RunBre发送主题消息时，在消息属性中添加CorrelationId（设为会话ID）和ReplyTo（指定响应队列名称）。
• StubSatellite处理后，发送响应消息到ReplyTo队列，并保持CorrelationId与原会话ID一致。
• RunBre使用Receive message动作接收消息后，通过判断CorrelationId匹配目标响应，确保会话关联的准确性。

验证要点 #

1. 确认响应队列中目标会话处于活动状态，且消息未被其他接收者锁定。
2. 检查RunBre传入的会话ID与StubSatellite发送的完全一致（注意大小写、无多余空格）。
3. 确保Service Bus连接器的身份具备队列的Listen或Manage权限。

内容的提问来源于stack exchange，提问作者Rob Bowman