Eventos
Compilación de Intelligent Apps
17 mar, 21 - 21 mar, 10
Únase a la serie de reuniones para crear soluciones de inteligencia artificial escalables basadas en casos de uso reales con compañeros desarrolladores y expertos.
Regístrese ahoraDiagnóstico con Durable Functions en Azure
Existen varias opciones para diagnosticar problemas con Durable Functions. Algunas de ellas son las mismas que para las funciones normales y otras son exclusivas de Durable Functions.
Application Insights es la manera recomendada para realizar el diagnóstico y la supervisión en Azure Functions. Lo mismo se aplica a Durable Functions. Para introducción al aprovechamiento de Application Insights en las aplicaciones de función, consulte Supervisión de Azure Functions.
La extensión Azure Durable Functions también emite eventos de seguimiento que permiten realizar el seguimiento de la ejecución de un extremo de una orquestación al otro. Estos eventos de seguimiento se pueden encontrar y consultar mediante la herramienta Application Insights Analytics de Azure Portal.
Cada evento de ciclo de vida de una instancia de orquestación provoca uno de seguimiento que se escribirá en la colección Seguimientos de Application Insights. Este evento contiene una carga customDimensions con varios campos. Los nombres de campo llevan prop__ antepuesto.
- hubName: nombre de la central de tareas donde se ejecutan las orquestaciones.
- appName: Nombre de la aplicación de función. Este campo resulta útil cuando se tienen varias aplicaciones de función que comparten la misma instancia de Application Insights.
- slotName: la ranura de implementación donde se ejecuta la aplicación de función actual. Este campo resulta útil cuando se utilizan las ranuras de implementación para modificar las orquestaciones.
- functionName: nombre de la función de actividad o de orquestador.
- functionType: tipo de función, como Orquestador o Actividad.
- instanceId: identificador único de la instancia de orquestación.
- state: estado de ejecución del ciclo de vida de la instancia. Los valores válidos son:
- Scheduled: la función estaba programada para ejecutarse, pero no se ha iniciado todavía la ejecución.
- Started: la función ha empezado a ejecutarse, pero todavía no está en espera ni completada.
- Awaited: el orquestador ha programado trabajo y está esperando a que finalice.
- Listening: el orquestador está escuchando una notificación de eventos externa.
- Completed: la función se ha completado correctamente.
- Error: se ha producido un error en la función.
- reason: información adicional asociada al evento de seguimiento. Por ejemplo, si una instancia está esperando una notificación de eventos externa, este campo indica el nombre del evento al que espera. Si se produce un error en una función, este campo contiene los detalles del error.
- isReplay: valor booleano que indica si el evento de seguimiento va a volver a reproducir la ejecución.
- extensionVersion: versión de la extensión Durable Task. La información de versión es especialmente importante al notificar posibles errores en la extensión. Las instancias de ejecución prolongada pueden notificar varias versiones si se produce una actualización mientras se están ejecutando.
- sequenceNumber: número de secuencia de ejecución de un evento. En combinación con timestamp, ayuda a ordenar los eventos por hora de ejecución. Tenga en cuenta que este número se restablecerá a cero si se reinicia el host mientras se ejecuta la instancia, por lo que es importante que siempre se ordene por timestamp en primer lugar y, a continuación, por sequenceNumber.
El nivel de detalle de los datos de seguimiento que se emiten para Application Insights puede configurarse en las secciones logger (Functions 1.x) o logging (Functions 2.0) del archivo host.json.
JSON
{
"logger": {
"categoryFilter": {
"categoryLevels": {
"Host.Triggers.DurableTask": "Information"
}
}
}
}
JSON
{
"logging": {
"logLevel": {
"Host.Triggers.DurableTask": "Information",
},
}
}
De forma predeterminada, se emiten todos los eventos de seguimiento de no reproducción. Se puede reducir el volumen de datos; para ello, configure Host.Triggers.DurableTask en "Warning" o "Error", en cuyo caso los eventos de seguimiento solo se emitirá para las situaciones excepcionales. Para habilitar la emisión de los eventos de reproducción de orquestación detallados, establezca logReplayEvents en true en el archivo de configuración host.json.
Nota
De forma predeterminada, el sistema en tiempo de ejecución de Azure Functions muestrea la telemetría de Application Insights para evitar que se emitan datos con demasiada frecuencia. Esto puede provocar que se pierda información de seguimiento cuando se producen muchos eventos de ciclo de vida en un breve período de tiempo. En el artículo Supervisión de Azure Functions se explica cómo configurar este comportamiento.
De forma predeterminada, las entradas y salidas de las funciones de orquestador, actividad y entidad no se registran. Se recomienda este comportamiento predeterminado porque el registro de entradas y salidas podría aumentar los costos de Application Insights. Las cargas de entrada y salida de funciones también pueden contener información confidencial. En su lugar, de forma predeterminada se registra el número de bytes para las entradas y salidas de funciones, en lugar de las cargas reales. Si quiere que la extensión Durable Functions registre las cargas de entrada y salida completas, establezca la propiedad traceInputsAndOutputs en true en el archivo de configuración host.json.
La consulta siguiente muestra datos históricos de seguimiento de una única instancia de la función de orquestación Hello Sequence. Se escribe con el lenguaje de consulta de Kusto. Filtra la ejecución de la reproducción de manera que se muestra solo la ruta de ejecución lógica. Los eventos se pueden ordenar por timestamp y sequenceNumber, tal y como se muestra en la siguiente consulta:
Kusto
let targetInstanceId = "ddd1aaa685034059b545eb004b15d4eb";
let start = datetime(2018-03-25T09:20:00);
traces
| where timestamp > start and timestamp < start + 30m
| where customDimensions.Category == "Host.Triggers.DurableTask"
| extend functionName = customDimensions["prop__functionName"]
| extend instanceId = customDimensions["prop__instanceId"]
| extend state = customDimensions["prop__state"]
| extend isReplay = tobool(tolower(customDimensions["prop__isReplay"]))
| extend sequenceNumber = tolong(customDimensions["prop__sequenceNumber"])
| where isReplay != true
| where instanceId == targetInstanceId
| sort by timestamp asc, sequenceNumber asc
| project timestamp, functionName, state, instanceId, sequenceNumber, appName = cloud_RoleName
El resultado es una lista de eventos de seguimiento que muestran la ruta de ejecución de la orquestación, funciones de actividad incluidas, ordenadas por hora de ejecución en orden ascendente.
La consulta siguiente muestra el estado de todas las instancias de orquestación que se ejecutaron en un intervalo de tiempo especificado.
Kusto
let start = datetime(2017-09-30T04:30:00);
traces
| where timestamp > start and timestamp < start + 1h
| where customDimensions.Category == "Host.Triggers.DurableTask"
| extend functionName = tostring(customDimensions["prop__functionName"])
| extend instanceId = tostring(customDimensions["prop__instanceId"])
| extend state = tostring(customDimensions["prop__state"])
| extend isReplay = tobool(tolower(customDimensions["prop__isReplay"]))
| extend output = tostring(customDimensions["prop__output"])
| where isReplay != true
| summarize arg_max(timestamp, *) by instanceId
| project timestamp, instanceId, functionName, state, output, appName = cloud_RoleName
| order by timestamp asc
El resultado es una lista de identificadores de instancia y su estado actual en tiempo de ejecución.
Los registros de extensión de Durable son útiles para comprender el comportamiento de la lógica de la orquestación. Sin embargo, estos registros no siempre contienen suficiente información para depurar problemas de confiabilidad y rendimiento a nivel del marco. A partir de la versión 2.3.0 de la extensión de Durable, los registros emitidos por el marco Durable Task Framework (DTFx) subyacente también están disponibles para la recopilación.
Cuando se examinan los registros emitidos por DTFx, es importante comprender que el motor de DTFx consta de dos componentes: el motor de distribución principal (DurableTask.Core) y uno de los muchos proveedores de almacenamiento admitidos (Durable Functions usa DurableTask.AzureStorage de manera predeterminada, pero hay otras opciones disponibles).
- DurableTask.Core: ejecución de orquestaciones principales y registros de programación y telemetría de bajo nivel.
- DurableTask.AzureStorage: registros de back-end específicos del proveedor de estado de Azure Storage. Estos registros incluyen interacciones detalladas con las colas internas, los blobs y las tablas de almacenamiento que se usan para almacenar y capturar el estado interno de la orquestación.
- DurableTask.Netherite: registros de back-end específicos del proveedor de almacenamiento de Netherite, si está habilitado.
- DurableTask.SqlServer: registros de back-end específicos del proveedor de almacenamiento de Microsoft SQL (MSSQL), si está habilitado.
Puede habilitar estos registros actualizando la sección logging/logLevel del archivo host.json de la aplicación de funciones. En el ejemplo siguiente, se muestra cómo habilitar los registros de advertencia y de error de DurableTask.Core y DurableTask.AzureStorage:
JSON
{
"version": "2.0",
"logging": {
"logLevel": {
"DurableTask.AzureStorage": "Warning",
"DurableTask.Core": "Warning"
}
}
}
Si ha habilitado Application Insights, estos registros se agregarán automáticamente a la colección trace. Puede buscarlos de la misma manera que busca otros registros trace mediante consultas de Kusto.
Nota
En el caso de las aplicaciones de producción, se recomienda habilitar DurableTask.Core y los registros de proveedor de almacenamiento adecuados (por ejemplo, DurableTask.AzureStorage) mediante el filtro "Warning". Los filtros con mayor nivel de detalle, como "Information", son muy útiles para depurar problemas de rendimiento. Sin embargo, estos eventos de registro pueden ser de gran volumen y aumentar significativamente los costos de almacenamiento de datos de Application Insights.
La siguiente consulta de Kusto muestra cómo consultar los registros de DTFx. La parte más importante de la consulta es where customerDimensions.Category startswith "DurableTask", ya que filtra los resultados por registros en las categorías DurableTask.Core y DurableTask.AzureStorage.
Kusto
traces
| where customDimensions.Category startswith "DurableTask"
| project
timestamp,
severityLevel,
Category = customDimensions.Category,
EventId = customDimensions.EventId,
message,
customDimensions
| order by timestamp asc
El resultado es un conjunto de registros escritos por los proveedores de registro de Durable Task Framework.
Para más información sobre los eventos de registro que están disponibles, vea la documentación sobre los registros estructurados de Durable Task Framework en GitHub.
Es importante tener en cuenta el comportamiento de reproducción del orquestador al escribir registros directamente desde una función de orquestador. Por ejemplo, considere la función de orquestador siguiente:
C#
[FunctionName("FunctionChain")]
public static async Task Run(
[OrchestrationTrigger] IDurableOrchestrationContext context,
ILogger log)
{
log.LogInformation("Calling F1.");
await context.CallActivityAsync("F1");
log.LogInformation("Calling F2.");
await context.CallActivityAsync("F2");
log.LogInformation("Calling F3");
await context.CallActivityAsync("F3");
log.LogInformation("Done!");
}
Los datos de registro resultantes se parecen a la siguiente salida de ejemplo:
txt
Calling F1.
Calling F1.
Calling F2.
Calling F1.
Calling F2.
Calling F3.
Calling F1.
Calling F2.
Calling F3.
Done!
Nota
Recuerde que, aunque los registros notifiquen una llamada a F1, F2 y F3, a estas funciones solo se las llama realmente la primera vez que se encuentran. Las llamadas posteriores que se producen durante la reproducción se omiten y las salidas se reproducen en la lógica del orquestador.
Si desea escribir únicamente registros en ejecuciones sin reproducción, puede escribir una expresión condicional para que registre solo si la marca "is replaying" es false. Considere el ejemplo anterior, pero esta vez con comprobaciones de reproducción.
C#
[FunctionName("FunctionChain")]
public static async Task Run(
[OrchestrationTrigger] IDurableOrchestrationContext context,
ILogger log)
{
if (!context.IsReplaying) log.LogInformation("Calling F1.");
await context.CallActivityAsync("F1");
if (!context.IsReplaying) log.LogInformation("Calling F2.");
await context.CallActivityAsync("F2");
if (!context.IsReplaying) log.LogInformation("Calling F3");
await context.CallActivityAsync("F3");
log.LogInformation("Done!");
}
A partir de Durable Functions 2.0, las funciones de orquestador de .NET también tienen la opción de crear un elemento ILogger que filtra automáticamente las instrucciones de registro durante la reproducción. Este filtrado automático se realiza mediante la API IDurableOrchestrationContext.CreateReplaySafeLogger(ILogger).
C#
[FunctionName("FunctionChain")]
public static async Task Run(
[OrchestrationTrigger] IDurableOrchestrationContext context,
ILogger log)
{
log = context.CreateReplaySafeLogger(log);
log.LogInformation("Calling F1.");
await context.CallActivityAsync("F1");
log.LogInformation("Calling F2.");
await context.CallActivityAsync("F2");
log.LogInformation("Calling F3");
await context.CallActivityAsync("F3");
log.LogInformation("Done!");
}
Nota
Los ejemplos de C# anteriores corresponden a Durable Functions 2.x. En el caso de Durable Functions 1.x, debe usar DurableOrchestrationContext en lugar de IDurableOrchestrationContext. Para obtener más información sobre las diferencias entre versiones, vea el artículo Versiones de Durable Functions.
Con los cambios mencionados anteriormente, la salida del registro es la siguiente:
txt
Calling F1.
Calling F2.
Calling F3.
Done!
El estado de orquestación personalizada le permite establecer un valor de estado personalizado para la función del orquestador. Este estado personalizado pueden verlo los clientes externos a través de la API de consulta de estado HTTP o de llamadas API específicas del lenguaje. El estado de orquestación personalizada habilita una supervisión más completa para las funciones del orquestador. Por ejemplo, el código de la función del orquestador pueden invocar la API "set custom status" para actualizar el progreso de una operación de ejecución prolongada. Un cliente, como una página web u otro sistema externo, puede entonces consultar periódicamente las API de consulta de estado HTTP para obtener una información más completa del progreso. A continuación, se proporciona código de ejemplo para establecer un valor de estado personalizado en una función de orquestador:
C#
[FunctionName("SetStatusTest")]
public static async Task SetStatusTest([OrchestrationTrigger] IDurableOrchestrationContext context)
{
// ...do work...
// update the status of the orchestration with some arbitrary data
var customStatus = new { completionPercentage = 90.0, status = "Updating database records" };
context.SetCustomStatus(customStatus);
// ...do more work...
}
Nota
El ejemplo de C# anterior corresponde a Durable Functions 2.x. En el caso de Durable Functions 1.x, debe usar DurableOrchestrationContext en lugar de IDurableOrchestrationContext. Para obtener más información sobre las diferencias entre versiones, vea el artículo Versiones de Durable Functions.
Mientras se ejecuta la orquestación, los clientes externos pueden capturar este estado personalizado:
HTTP
GET /runtime/webhooks/durabletask/instances/instance123?code=XYZ
Los clientes obtendrán la siguiente respuesta:
JSON
{
"runtimeStatus": "Running",
"input": null,
"customStatus": { "completionPercentage": 90.0, "status": "Updating database records" },
"output": null,
"createdTime": "2017-10-06T18:30:24Z",
"lastUpdatedTime": "2017-10-06T19:40:30Z"
}
Advertencia
La carga de estado personalizada se limita a 16 KB de texto JSON de UTF-16, ya que debe caber en una columna de Azure Table Storage. Puede usar almacenamiento externo si necesita una carga útil mayor.
El seguimiento distribuido realiza un seguimiento de las solicitudes y muestra cómo interactúan los distintos servicios entre sí. En Durable Functions, también correlaciona las orquestaciones y las actividades juntas. Esto resulta útil para comprender cuánto tiempo tardan los pasos de la orquestación en relación con toda la orquestación. También es útil comprender dónde tiene una aplicación un problema o dónde se produjo una excepción. Esta característica es compatible con todos los lenguajes y proveedores de almacenamiento.
Nota
El seguimiento distribuido V2 requiere Durable Functions v2.12.0 o posterior. Además, el seguimiento distribuido V2 está en un estado de versión preliminar y, por tanto, algunos patrones de Durable Functions no están instrumentados. Por ejemplo, las operaciones de Durable Entities no se instrumentan y los seguimientos no se mostrarán en Application Insights.
Para configurar el seguimiento distribuido, actualice el host.json y configure un recurso de Application Insights.
"durableTask": {
"tracing": {
"distributedTracingEnabled": true,
"Version": "V2"
}
}
Si la aplicación de funciones no está configurada con un recurso de Application Insights, configúrela siguiendo las instrucciones que se indican aquí.
En el recurso de Application Insights, vaya a Búsqueda de transacciones. En los resultados, compruebe si están los eventos Request y Dependency que comienzan con prefijos específicos de Durable Functions (por ejemplo orchestration:, activity:, etc.). Al seleccionar uno de estos eventos, se abrirá un diagrama de Gantt que mostrará el seguimiento distribuido en su conjunto.
Si no ve los seguimientos en Application Insights, asegúrese de esperar unos cinco minutos después de ejecutar la aplicación para asegurarse de que todos los datos se propagan al recurso de Application Insights.
Azure Functions admite la depuración directa de código de función y esa misma compatibilidad se traslada a Durable Functions, tanto si se ejecuta en Azure o localmente. Sin embargo, hay algunos comportamientos que tener en cuenta al depurar:
- Reproducción: las funciones de orquestador suelen reproducir cuando se reciben nuevas entradas. Este comportamiento significa que una sola ejecución lógica de una función de orquestador puede dar lugar a que se alcance el mismo punto de interrupción varias veces, especialmente si se establece al principio del código de la función.
- Espera: siempre que se encuentre un
awaiten una función de orquestador, devuelve el control al distribuidor de Durable Task Framework. Si se trata de la primera vez que se encuentra una instrucciónawaitdeterminada, la tarea asociada nunca se reanuda. Puesto que la tarea nunca se reanuda, no se puede omitir la instrucción await (F10 en Visual Studio). La omisión solo funciona cuando se reproduce una tarea. - Tiempo de expiración de los mensajes: Durable Functions usa mensajes de cola internos para dirigir la ejecución de las funciones tanto de orquestador como de actividad o de entidad. En un entorno de varias máquinas virtuales, iniciar la depuración durante largos períodos de tiempo podría provocar que otra máquina virtual recogiera el mensaje, lo que provocaría la duplicación de la ejecución. Este comportamiento también existe para las funciones con desencadenador de cola normales, pero es importante señalarlo en este contexto, ya que las colas son un detalle de la implementación.
- Detención e inicio: los mensajes de Durable Functions se conservan entre las sesiones de depuración. Si detiene la depuración y termina el proceso de host local mientras se está ejecutando una función de Durable Functions, dicha función se puede volver a ejecutar automáticamente en una sesión de depuración futura. Este comportamiento puede resultar confuso cuando no se espera. Usar un nuevo centro de tareas o borrar el contenido del centro de tareas entre sesiones de depuración es una técnica para evitar este comportamiento.
Sugerencia
Al establecer puntos de interrupción en las funciones de orquestador, si desea interrumpir solo la ejecución sin reproducción, puede establecer un punto de interrupción condicional que solo se interrumpa si el valor de "is replaying" es false.
De forma predeterminada, Durable Functions almacena el estado en Azure Storage. Este comportamiento significa que puede inspeccionar el estado de las orquestaciones con herramientas como el Explorador de Microsoft Azure Storage.
Esto es útil para la depuración, porque verá el estado concreto de las orquestaciones. También se pueden examinar los mensajes de las colas para conocer el trabajo pendiente (o bloqueado, en algunos casos).
Advertencia
Aunque es conveniente ver el historial de ejecución en Table Storage, no se fie de esta tabla. Puede cambiar con el progreso de la extensión Durable Functions.
Nota
Se pueden configurar otros proveedores de almacenamiento en lugar del proveedor de Azure Storage predeterminado. Dependiendo del proveedor de almacenamiento configurado para la aplicación, es posible que tenga que usar diferentes herramientas para inspeccionar el estado subyacente. Para más información, consulte la documentación de Proveedores de almacenamiento de Durable Functions.
Durable Functions Monitor es una herramienta gráfica para supervisar, administrar y depurar instancias de orquestación y entidad. Está disponible como una extensión de Visual Studio Code o una aplicación independiente. Puede encontrar información sobre la configuración y una lista de características en esta Wiki.
Para solucionar síntomas de problemas comunes, como orquestaciones que se bloquean, que no se inician, que se ejecutan de forma lenta, etc., consulte esta guía de solución de problemas.
Recursos adicionales
Cursos
Ruta de aprendizaje
Use advance techniques in canvas apps to perform custom updates and optimization - Training
Use advance techniques in canvas apps to perform custom updates and optimization