Skip to content

Azure WebJobs SDK: QueueTrigger fails to connect to Azure Storage Queue in Fairfax (US Gov) but works for Blob/Table triggers" #3132

@kmittal30

Description

@kmittal30

Azure Function queue trigger fails to connect to Azure Storage Queue in Fairfax (US Gov) cloud, while blob and table triggers work with the same storage account and credentials. Removing the queue trigger resolves the issue.

Note this is happening only in Fairfax cloud. In farifax only issue is coming with queue trigger not timer trigger.

Environment:

  • .NET Framework: 4.6.2
  • Microsoft.Azure.WebJobs.Extensions: 5.0.0
  • Microsoft.Azure.WebJobs.Extensions.Storage: 5.3.0
  • Microsoft.Azure.WebJobs.Host.Storage: 5.0.0
  • Azure.Storage.Queues: 12.18.0
  • Hosting: [App Service]
  • Region: Fairfax (US Gov)

Configuration:

Trigger and Code:

public static void ProcessPeriodicErrorCountLoggerMessage(
    [QueueTrigger("periodic-error-count-logger-queue")] string message,
    ILogger logger)
{
    // ... function body ...
}

public static void ProcessQueueMessage([QueueTrigger("auto-mitigation-queue")] string message, ILogger logger) {}

Error logs :

In eventlog.xml the below error is coming and the app is crashing almost every min.

</Data></EventData></Event><Event><System><Provider Name=".NET Runtime"/><EventID>1026</EventID><Level>1</Level><Task>0</Task><Keywords>Keywords</Keywords><TimeCreated SystemTime="2025-05-15T05:58:28Z"/><EventRecordID>579840609</EventRecordID><Channel>Application</Channel><Computer>DW1LDWK0000C8</Computer><Security/></System><EventData><Data>Application: AppGatewayMonitoringService.exe Framework Version: v4.0.30319 Description: The process was terminated due to an unhandled exception. Exception Info: System.Net.WebException at System.Net.HttpWebRequest.EndGetResponse(System.IAsyncResult) at System.Threading.Tasks.TaskFactory1[[System.__Canon, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089]].FromAsyncCoreLogic(System.IAsyncResult, System.Func2&lt;System.IAsyncResult,System.__Canon&gt;, System.Action1<System.IAsyncResult>, System.Threading.Tasks.Task1&lt;System.__Canon&gt;, Boolean) at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Azure.Core.Pipeline.HttpWebRequestTransport+&lt;ProcessInternal&gt;d__8.MoveNext() Exception Info: Azure.RequestFailedException at Azure.Core.Pipeline.HttpWebRequestTransport+&lt;ProcessInternal&gt;d__8.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Azure.Core.Pipeline.HttpWebRequestTransport+&lt;ProcessAsync&gt;d__7.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Azure.Core.Pipeline.HttpPipelineTransportPolicy+&lt;ProcessAsync&gt;d__4.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Azure.Core.Pipeline.ResponseBodyPolicy+&lt;ProcessAsync&gt;d__5.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Azure.Core.Pipeline.LoggingPolicy+&lt;ProcessAsync&gt;d__9.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Azure.Core.Pipeline.BearerTokenAuthenticationPolicy+&lt;ProcessAsync&gt;d__11.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Azure.Core.Pipeline.HttpPipelineSynchronousPolicy+&lt;InnerProcessAsync&gt;d__5.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Azure.Core.Pipeline.RedirectPolicy+&lt;ProcessAsync&gt;d__7.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at Azure.Core.Pipeline.RetryPolicy+&lt;ProcessAsync&gt;d__5.MoveNext() Exception Info: System.AggregateException at Azure.Core.Pipeline.RetryPolicy+&lt;ProcessAsync&gt;d__5.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Azure.Core.Pipeline.HttpPipelineSynchronousPolicy+&lt;InnerProcessAsync&gt;d__5.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Azure.Storage.Queues.QueueRestClient+&lt;GetPropertiesAsync&gt;d__14.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Azure.Storage.Queues.QueueClient+&lt;GetPropertiesInternal&gt;d__61.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Azure.Storage.Queues.QueueClient+&lt;ExistsInternal&gt;d__52.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Azure.Storage.Queues.QueueClient+&lt;ExistsAsync&gt;d__51.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Threading.Tasks.Task) at Microsoft.Azure.WebJobs.Extensions.Storage.Common.Listeners.QueueListener+&lt;ExecuteAsync&gt;d__34.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at Microsoft.Azure.WebJobs.Extensions.Storage.Common.Timers.TaskSeriesTimer+&lt;RunAsync&gt;d__14.MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext, System.Threading.ContextCallback, System.Object, Boolean) at System.Threading.ExecutionContext.Run(System.Threading.ExecutionContext, System.Threading.ContextCallback, System.Object, Boolean) at System.Threading.ExecutionContext.Run(System.Threading.ExecutionContext, System.Threading.ContextCallback, System.Object) at System.Threading.ThreadHelper.ThreadStart()

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions