Support for Microsoft.Azure.Functions.Worker.Extensions.DurableTask.SqlServer

[olahallvall]

Hi!
First; Thanks for building a tool for Durable Functions :)

Do the DurableFunctionsMonitor have support for Microsoft.Azure.Functions.Worker.Extensions.DurableTask.SqlServer?

[scale-tone]

Hey @olahallvall , if you mean Durable Task SQL Provider used in a .NET Isolated project, then yes.

VsCode extension should automatically show you your Task Hubs and let you connect to them (no matter if they're from an InProc or Isolated project).

Standalone DfMon instance to monitor your Task Hubs can be deployed out of this one or this one (both should work).

To inject DfMon into your .NET Isolated + MSSQL project you can just copy-paste code from here.

[olahallvall]

Hi again,
Hm I have based my solution on the Visual Studio project type Azure Functions.

Below is a Hello World project based on Azure Functions* project type.

using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Http;
using Microsoft.DurableTask;
using Microsoft.DurableTask.Client;
using Microsoft.Extensions.Logging;

namespace FunctionAppOrchestration
{
    public static class Function1
    {
        [Function(nameof(Function1))]
        public static async Task<List<string>> RunOrchestrator(
            [OrchestrationTrigger] TaskOrchestrationContext context)
        {
            ILogger logger = context.CreateReplaySafeLogger(nameof(Function1));
            logger.LogInformation("Saying hello.");
            var outputs = new List<string>();

            // Replace name and input with values relevant for your Durable Functions Activity
            outputs.Add(await context.CallActivityAsync<string>(nameof(SayHello), "Tokyo"));
            outputs.Add(await context.CallActivityAsync<string>(nameof(SayHello), "Seattle"));
            outputs.Add(await context.CallActivityAsync<string>(nameof(SayHello), "London"));

            // returns ["Hello Tokyo!", "Hello Seattle!", "Hello London!"]
            return outputs;
        }

        [Function(nameof(SayHello))]
        public static string SayHello([ActivityTrigger] string name, FunctionContext executionContext)
        {
            ILogger logger = executionContext.GetLogger("SayHello");
            logger.LogInformation("Saying hello to {name}.", name);
            return $"Hello {name}!";
        }

        [Function("Function1_HttpStart")]
        public static async Task<HttpResponseData> HttpStart(
            [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequestData req,
            [DurableClient] DurableTaskClient client,
            FunctionContext executionContext)
        {
            ILogger logger = executionContext.GetLogger("Function1_HttpStart");

            // Function input comes from the request content.
            string instanceId = await client.ScheduleNewOrchestrationInstanceAsync(
                nameof(Function1));

            logger.LogInformation("Started orchestration with ID = '{instanceId}'.", instanceId);

            // Returns an HTTP 202 response with an instance management payload.
            // See https://learn.microsoft.com/azure/azure-functions/durable/durable-functions-http-api#start-orchestration
            var resp = await client.CreateCheckStatusResponseAsync(req, instanceId);

            return resp;
        }
    }
}

This project type seems to have no dependency to Webjobs (https://learn.microsoft.com/en-us/azure/app-service/webjobs-create?tabs=windowscode) as I see it! I can be wrong :-)

My understanding is that Azure Functions (https://learn.microsoft.com/en-us/azure/azure-functions/functions-overview?pivots=programming-language-csharp) probably have a different way of work compared to Webjobs?

Tables that Azure Functions using

[olahallvall]

Sorry my bad!

"To inject DfMon into your .NET Isolated + MSSQL project you can just copy-paste code from here." works well.

[olahallvall]

Get these lines in my log.

[2024-08-30T07:18:53.439Z] Executed 'Functions.DfmAboutFunction' (Succeeded, Id=ac289c45-954b-4255-9bdb-8d824fc3163e, Duration=69ms)
[2024-08-30T07:18:54.737Z] Executed 'Functions.DfmGetOrchestrationsFunction' (Succeeded, Id=d966ac79-8cb3-48ce-8825-90f6f3ba4c8e, Duration=1358ms)
[2024-08-30T07:18:54.741Z] Failed to list Durable Entities
[2024-08-30T07:18:54.742Z] Result: Failed to list Durable Entities
Exception: Grpc.Core.RpcException: Status(StatusCode="Unimplemented", Detail="Missing entity support for storage backend 'DurableTask.SqlServer.SqlOrchestrationService'. Entity support may have not been implemented yet, or the selected package version is too old.")
[2024-08-30T07:18:54.745Z] at Microsoft.DurableTask.Client.Grpc.GrpcDurableEntityClient.<>c__DisplayClass11_01.<<GetAllEntitiesCoreAsync>b__0>d.MoveNext() [2024-08-30T07:18:54.747Z] --- End of stack trace from previous location --- [2024-08-30T07:18:54.749Z] at Microsoft.DurableTask.Pageable.FuncAsyncPageable1.AsPagesCore(String continuationToken, Nullable1 pageSizeHint, CancellationToken cancellation)+MoveNext() [2024-08-30T07:18:54.752Z] at Microsoft.DurableTask.Pageable.FuncAsyncPageable1.AsPagesCore(String continuationToken, Nullable1 pageSizeHint, CancellationToken cancellation)+System.Threading.Tasks.Sources.IValueTaskSource<System.Boolean>.GetResult() [2024-08-30T07:18:54.754Z] at Microsoft.DurableTask.AsyncPageable1.GetAsyncEnumerator(CancellationToken cancellationToken)+MoveNext()
[2024-08-30T07:18:54.757Z] at Microsoft.DurableTask.AsyncPageable1.GetAsyncEnumerator(CancellationToken cancellationToken)+MoveNext() [2024-08-30T07:18:54.759Z] at Microsoft.DurableTask.AsyncPageable1.GetAsyncEnumerator(CancellationToken cancellationToken)+System.Threading.Tasks.Sources.IValueTaskSource<System.Boolean>.GetResult()
[2024-08-30T07:18:54.761Z] Executing 'Functions.DfmGetOrchestrationsFunction' (Reason='This function was programmatically called via the host APIs.', Id=d8d28b02-8c21-4379-b341-9392f52818f3)