SendMessageAsync и CompleteMessageAsync в одной AzureFunction?. ошибка Транзакция еще не объявлена ​​или уже выполнена ⇐ C#

[Anonymous]

Когда сообщение получено в теме служебной шины Azure, функция My Azure срабатывает, она отправляет одно новое сообщение в другую очередь и завершает текущее сообщение, чтобы оно не сработало снова. но в приведенном ниже коде SendMessageAsync завершается нормально, но когда вызовы CompleteMessageAsync получают исключение "Транзакция еще не объявлена ​​или уже выполнена": требуется помощь, чтобы это исправить
public class Function1
{
[FunctionName("Function1")]
//public void Run([ServiceBusTrigger("%ServiceBusTopicName%", "%ServiceBusSubscriptionName%", Connection = "ServiceBusConnectionString", IsSessionsEnabled = true)]string mySbMsg, ILogger log)
// public async Task Run([ServiceBusTrigger("%ServiceBusTopicName%", "%ServiceBusSubscriptionName%", Connection = "ServiceBusConnectionString", IsSessionsEnabled = true)]string mySbMsg, ILogger log)

public async Task Run([ServiceBusTrigger("%ServiceBusTopicName%", "%ServiceBusSubscriptionName%", Connection = "ServiceBusConnectionString",IsSessionsEnabled =true)]
ServiceBusReceivedMessage message,
ServiceBusMessageActions messageActions)
{
string serviceBusConnectionstring = Environment.GetEnvironmentVariable("ServiceBusConnectionString");
string topicName = Environment.GetEnvironmentVariable("ServiceBusTopicName");
string subscriptionName = Environment.GetEnvironmentVariable("ServiceBusSubscriptionName");
string aiTopicName = Environment.GetEnvironmentVariable("ServiceBusAITopicName");
string aiTopicSubscriptionName = Environment.GetEnvironmentVariable("ServiceBusAISubscriptionName");
string zendeskUrl = Environment.GetEnvironmentVariable("ZendeskURL");
string userKey = Environment.GetEnvironmentVariable("UserKey");
var requestKey = 1;
var threadKey = 1;
Console.WriteLine($"C# ServiceBus topic trigger function processed message: {message}");
ServiceBusClientOptions options = new() { EnableCrossEntityTransactions = true };
await using var serviceBusClient = new ServiceBusClient(serviceBusConnectionstring, options);
ServiceBusSender sender = serviceBusClient.CreateSender(aiTopicName);

string jsonString = $@"{{""thread_key"": {threadKey}, ""request_key"": {requestKey}}}";
Console.WriteLine(jsonString); // Create a message and send it to the Service Bus queue
try
{

ServiceBusMessage msg = new ServiceBusMessage(jsonString)
{
SessionId = threadKey.ToString()
};
using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
{
**await sender.SendMessageAsync(msg);**
Console.WriteLine("Connector Processor: SendMessageAsync completed");
**await messageActions.CompleteMessageAsync(message);**
Console.WriteLine("Connector Processor: CompleteMessageAsync completed");
scope.Complete();
}
}
catch (Exception ex)
{
string errorMessage = ex.Message.ToString();
Console.WriteLine("Connector Processor: Exception: {Message}- error log");
Console.WriteLine("Connector Processor: Exception: {Message}", errorMessage);

if (ex.InnerException != null)
{
errorMessage += " | Inner Exception: " + ex.InnerException.Message;
}
Console.WriteLine("Connector Processor: Exception: {Message}", errorMessage);
// Handle Service Bus message retries or deferral
/* if (messageActions != null)
{
try
{
// Option 1: Abandon the message so it can be retried
await messageActions.AbandonMessageAsync(message);
}
catch (Exception abandonEx)
{
Console.WriteLine("Connector Processor:Failed to abandon message: {Message}", abandonEx.Message);
}
}*/
}
}
}


Подробнее здесь: https://stackoverflow.com/questions/792 ... error-tran