Az OEPAirFlowTask tábla lekérdezései
A lekérdezések Azure Portalon való használatáról további információt a Log Analytics oktatóanyagában talál. A REST API-val kapcsolatban lásd a Lekérdezést.
DAG-típus és DAG-futtatás összefoglaló statitics
DAG-futtatások száma az adott időtartományban lévő DAG-típus egyes típusaihoz
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
Az összes DAG-futtatás korrelációs azonosítói
Az időtartományban (az összes DAG-típushoz) tartozó összes DAG-futtatás korrelációs azonosítói
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
DAG-futtatás naplói
Lekéri egy adott AirFlow DAG-futtatás naplóit a korrelációs azonosító és az időtartomány alapján.
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
DAG-futtatás hibanaplói
Egy adott AirFlow DAG-futtatás hibanaplóit kéri le a korrelációs azonosító és az időtartomány alapján.
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