Interrogazioni per la tabella OEPAirFlowTask

Per informazioni sull'uso di queste query nel portale di Azure, vedere Esercitazione su Log Analytics. Per l'API REST, vedere Query.

Statistiche di riepilogo di tipo DAG rispetto a esecuzioni DAG

Numero di esecuzioni DAG per ogni tipo di DAG nell'intervallo di tempo specificato

OEPAirFlowTask
| extend ResourceName = tostring(split(_ResourceId , '/')[-1])
// | where ResourceName == "<the name of ADME instance>"        // to filter on resourceName replace <...> and uncomment line
| distinct DagName, CorrelationId                               // correlationId is same as runId - we have created a duplicate for consistency in search across logs of all services 
| sort by DagName asc

ID di correlazione di tutte le esecuzioni DAG

ID di correlazione di tutte le esecuzioni di DAG che si sono verificate nell'intervallo di tempo (per tutti i tipi DIG)

OEPAirFlowTask
| extend ResourceName = tostring(split(_ResourceId , '/')[-1])
// | where ResourceName == "<the name of ADME instance>"        // to filter on resourceName replace <...> and uncomment line
| distinct DagName, CorrelationId                               // correlationId is same as runId - we have created a duplicate for consistency in search across logs of all services 
| summarize count() by DagName

Log di un'esecuzione DAG

Recupera i log per un'esecuzione DAG AirFlow specifica in base al correlationId e all'intervallo di tempo.

OEPAirFlowTask
| extend ResourceName = tostring(split(_ResourceId , '/')[-1])
// | where ResourceName == "<the name of ADME instance>"        // to filter on resourceName replace <...> and uncomment line
// | where CorrelationId == "<DAG run's runId>"                 // to filter on correlationID replace <...> with correlationId (same as runId) - we have created a duplicate for to maintain consistency of column name across all services 
| project TimeGenerated, DagName, LogLevel, DagTaskName, CodePath, Content

Log degli errori di un'esecuzione di DAG

Recupera i log degli errori per una determinata esecuzione di AirFlow DAG in base all'id di correlazione e all'intervallo di tempo.

OEPAirFlowTask
| extend ResourceName = tostring(split(_ResourceId , '/')[-1])
// | where ResourceName == "<the name of ADME instance>"        // to filter on resourceName replace <...> and uncomment line
// | where CorrelationId == "<DAG run's runId>"                 // to filter on correlationID replace <...> with correlationId (same as runId) - we have created a duplicate for to maintain consistency of column name across all services 
| where LogLevel  == "ERROR"
| project TimeGenerated, DagName, LogLevel, DagTaskName, CodePath, Content