无法从Azure Function App向Azure Service Bus发送消息

1. 代码逻辑错误：仅发送最后一条记录 #

你的当前代码在while循环中每次覆盖jsonEmployee变量，最终仅返回最后一条Employee的JSON字符串——即便连接正常，队列也只会收到最后一条数据。要批量发送所有员工记录，需使用ICollector<string>或IAsyncCollector<string>类型的输出绑定，而非返回单个字符串。

修复后的代码示例 #

[FunctionName("ProcessEmployeeInput")]
public void Run(
    [BlobTrigger("%InputContainer%/%InputFolder%/{name}.txt", Connection = "StorageConnection")] Stream fileBlob, 
    string name, 
    ILogger log,
    [ServiceBus("myQueueName", Connection = "ServiceBusConnection")] ICollector<string> outputMessages)
{
    log.LogInformation($"Azure Function START.");
    log.LogInformation($"Processing file {name}.");

    try
    {
        using (var srFile = new StreamReader(fileBlob))
        {
            // 跳过表头
            var headerLine = srFile.ReadLine();
            if (string.IsNullOrEmpty(headerLine))
            {
                log.LogWarning("File has no content or only header.");
                return;
            }

            while (!srFile.EndOfStream)
            {
                var record = srFile.ReadLine();
                if (string.IsNullOrWhiteSpace(record)) continue;

                // 映射Employee对象
                Employee employee = MapEmployeeProperties(record, log);
                
                // 序列化并添加到输出集合
                string jsonEmployee = JsonConvert.SerializeObject(employee);
                outputMessages.Add(jsonEmployee);
                log.LogInformation($"Added employee record to queue: {employee.Id}");
            }
        }
    }
    catch (Exception ex)
    {
        log.LogError("Error processing file. {0} | {1} | {2}", ex.Message, ex.StackTrace, ex.InnerException?.Message);
    }
}

2. 连接超时问题排查 #

错误信息A connection attempt failed because the connected party did not properly respond...通常指向以下原因：

• 连接字符串有效性：确认连接字符串取自Service Bus命名空间的Shared Access Policies（而非队列级别政策，除非特意配置队列权限），格式应为Endpoint=sb://<your-namespace>.servicebus.windows.net/;SharedAccessKeyName=<policy-name>;SharedAccessKey=<key>。
• 网络限制：本地开发时，检查防火墙是否允许出站连接到Service Bus端口（默认5671用于AMQP，443用于HTTPS）；企业网络环境下可能需要申请白名单或配置代理。
• Service Bus资源状态：登录Azure门户确认你的Service Bus命名空间处于运行中状态，目标队列myQueueName已创建且未被禁用。

3. 调试连接字符串的方法 #

要验证函数是否正确读取ServiceBusConnection配置，可注入IConfiguration并打印日志：

// 在函数类构造函数中注入IConfiguration
private readonly IConfiguration _config;
public YourFunctionClass(IConfiguration config)
{
    _config = config;
}

// 在Run方法中添加日志验证
var sbConnection = _config["ServiceBusConnection"];
log.LogInformation("Service Bus Connection String (partial): {0}", sbConnection?.Substring(0, sbConnection.IndexOf(';')));

通过此方法可排查配置键名拼写错误、配置未加载等问题。

4. 额外优化建议 #

• 异步处理：若文件较大，建议使用异步流读取和IAsyncCollector<string>提升性能：

  public async Task Run(
      // 其他参数保持不变
      [ServiceBus("myQueueName", Connection = "ServiceBusConnection")] IAsyncCollector<string> outputMessages)
  {
      // ...
      while (!srFile.EndOfStream)
      {
          var record = await srFile.ReadLineAsync();
          // ...
          await outputMessages.AddAsync(jsonEmployee);
      }
  }
  

• 错误重试：可在Service Bus输出绑定中配置重试策略，或在代码中添加重试逻辑，避免临时网络问题导致消息丢失。
• 批量发送：若文件包含大量记录，可批量添加到ICollector，减少Service Bus连接开销。

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