Added dedicated module for azure functions

Author: dei79

dotNet/CoreHelpers.Extensions.Logging.DurableTask/CoreHelpers.Extensions.Logging.DurableTask.csproj

@@ -0,0 +1,16 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <TargetFramework>netstandard2.1</TargetFramework>
+        <Nullable>enable</Nullable>
+    </PropertyGroup>
+
+    <ItemGroup>
+      <PackageReference Include="Microsoft.Azure.Functions.Worker" Version="2.2.0" />
+      <PackageReference Include="Microsoft.DurableTask.Client" Version="1.16.1" />
+    </ItemGroup>
+
+    <ItemGroup>
+      <ProjectReference Include="..\CoreHelpers.Extensions.Logging.Tasks\CoreHelpers.Extensions.Logging.Tasks.csproj" />
+    </ItemGroup>
+</Project>

dotNet/CoreHelpers.Extensions.Logging.DurableTask/DurableTaskClientExtension.cs

@@ -0,0 +1,24 @@
+using CoreHelpers.Extensions.Logging.Tasks;
+using CoreHelpers.TaskLogging;
+using Microsoft.DurableTask;
+using Microsoft.Extensions.Logging;
+
+namespace CoreHelpers.Extensions.Logging.DurableTask
+{
+    public static class DurableTaskClientExtension
+    {
+        public static ITaskLoggerScope? BeginOrchestratorTaskLoggerContext(this ILogger logger, TaskOrchestrationContext context, ITaskLoggerFactory taskLoggerFactory)
+        {
+            // lookup the task log id 
+            var tasklogId = taskLoggerFactory.LookupTaskIdByExternalId(context.InstanceId).GetAwaiter().GetResult();
+            if (string.IsNullOrEmpty(tasklogId))
+            {
+                tasklogId = taskLoggerFactory.AnnounceTask(context.Name, context.Parent == null ? "OrchestratorInvocation" : "SubOrchestratorInvocation", "AzureFunctionsFlexConsumption").GetAwaiter().GetResult();
+                taskLoggerFactory.RegisterExternlIdForTask(tasklogId, context.InstanceId).GetAwaiter().GetResult();
+            }
+
+            // return the context
+            return logger.BeginTaskScope(tasklogId);
+        }
+    }
+}

dotNet/CoreHelpers.Extensions.Logging.DurableTask/InvocationTaskLoggingMiddleware.cs

@@ -0,0 +1,52 @@
+using System;
+using System.Linq;
+using System.Threading.Tasks;
+using CoreHelpers.Extensions.Logging.Tasks;
+using Microsoft.Azure.Functions.Worker;
+using Microsoft.Azure.Functions.Worker.Builder;
+using Microsoft.Azure.Functions.Worker.Middleware;
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Logging;
+
+namespace CoreHelpers.Extensions.Logging.DurableTask
+{
+    public static class FunctionsApplicationBuilderExtensions
+    {
+        public static FunctionsApplicationBuilder UseTaskLoggingMiddleware(this FunctionsApplicationBuilder builder)
+        {
+            builder.UseMiddleware<InvocationTaskLoggingMiddleware>();
+            return builder;
+        }
+    }
+
+    internal class InvocationTaskLoggingMiddleware : IFunctionsWorkerMiddleware
+    {
+        public async Task Invoke(FunctionContext context, FunctionExecutionDelegate next)
+        {
+            // figure out if it is an orchestration function
+            bool isOrchestration = context.FunctionDefinition.InputBindings.Values
+                .Any(b => b.Type.EndsWith("orchestrationTrigger", StringComparison.OrdinalIgnoreCase));
+
+            if (isOrchestration)
+            {
+                await next(context);
+            }
+            else
+            {
+                var logger = context.GetLogger(context.FunctionDefinition.Name);
+
+                using (logger.BeginNewTaskScope(context.FunctionDefinition.Name, "ActivityInvocation", "AzureFunctionsFlexConsumption"))
+                {
+                    try
+                    {
+                        await next(context);
+                    }
+                    catch (Exception ex)
+                    {
+                        logger.LogError(ex, "An unhandled exception occurred during function invocation.");
+                    }
+                }
+            }
+        }
+    }
+}

dotNet/TaskLogging.sln

@@ -11,6 +11,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CoreHelpers.TaskLogging.Sam
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CoreHelpers.Extensions.Logging.Tasks", "CoreHelpers.Extensions.Logging.Tasks\CoreHelpers.Extensions.Logging.Tasks.csproj", "{F6BBD6CC-795E-47D4-8F2C-27D4BC14E78F}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CoreHelpers.Extensions.Logging.DurableTask", "CoreHelpers.Extensions.Logging.DurableTask\CoreHelpers.Extensions.Logging.DurableTask.csproj", "{56E27924-4E2F-488C-BEFF-BC5AB91CCF8B}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -33,6 +35,10 @@ Global
 		{F6BBD6CC-795E-47D4-8F2C-27D4BC14E78F}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{F6BBD6CC-795E-47D4-8F2C-27D4BC14E78F}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{F6BBD6CC-795E-47D4-8F2C-27D4BC14E78F}.Release|Any CPU.Build.0 = Release|Any CPU
+		{56E27924-4E2F-488C-BEFF-BC5AB91CCF8B}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{56E27924-4E2F-488C-BEFF-BC5AB91CCF8B}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{56E27924-4E2F-488C-BEFF-BC5AB91CCF8B}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{56E27924-4E2F-488C-BEFF-BC5AB91CCF8B}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE