目前，您无法将CorrelationID修改为Azure Service Bus的只读属性。这是其属性的一部分。它类似于Content Type、ToReplyTo**，就像其他类型的消息模式一样。
但是，您可以将包括CorrelationID在内的服务总线属性格式化，并在代码中将其传递给输出消息，如Github Issue1、Github Issue2和Github Issue3中所引用的
下面是我的自定义中间件记录的CorrelationID，您可以使用此CorrelationId在您的输出消息如下：-

我的CorrelationIdMiddleware.cs：-

using System.Threading.Tasks;
using Azure.Messaging.ServiceBus;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Middleware;
using Microsoft.Extensions.Logging;

namespace FunctionApp66
{
    public class CorrelationIdMiddleware : IFunctionsWorkerMiddleware
    {
        private readonly ILogger<CorrelationIdMiddleware> _logger;

        public CorrelationIdMiddleware(ILogger<CorrelationIdMiddleware> logger)
        {
            _logger = logger;
        }

        public async Task Invoke(FunctionContext context, FunctionExecutionDelegate next)
        {
            if (context.BindingContext.BindingData.TryGetValue("ServiceBusTrigger", out var triggerData)
                && triggerData is ServiceBusReceivedMessage receivedMessage)
            {
                if (receivedMessage.ApplicationProperties.ContainsKey("CorrelationId"))
                {
                    var correlationId = (string)receivedMessage.ApplicationProperties["CorrelationId"];

                    // Log the correlation ID without modifying the message
                    _logger.LogInformation("Correlation ID: {correlationId}", correlationId);
                }
            }

            await next(context);
        }
    }
}

字符串

我的Function1.cs：-

using System;
using Azure.Messaging.ServiceBus;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.Logging;

namespace FunctionApp66
{
    public class Function1
    {
        private readonly ILogger<Function1> _logger;

        public Function1(ILogger<Function1> logger)
        {
            _logger = logger;
        }

        [Function(nameof(Function1))]
        public void Run([ServiceBusTrigger("myqueue", Connection = "myqueue")] ServiceBusReceivedMessage message)
        {
            _logger.LogInformation("Message ID: {id}", message.MessageId);
            _logger.LogInformation("Message Body: {body}", message.Body);
            _logger.LogInformation("Message Content-Type: {contentType}", message.ContentType);
            _logger.LogInformation("Message Content-Type: {contentType}", message.CorrelationId);
        }
    }
}

型

我的程序.cs：-

using FunctionApp66;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults()
    .ConfigureServices(services =>
    {
        services.AddApplicationInsightsTelemetryWorkerService();
        services.ConfigureFunctionsApplicationInsights();
        services.AddSingleton<CorrelationIdMiddleware>();

    })
    .Build();

host.Run();

型

输出：-

x1c 0d1x的数据