Abfragen für die OEPAirFlowTask-Tabelle
DAG-Typ im Vergleich zu DAG führt Zusammenfassungsstatitik aus
Anzahl der DAG-Ausführungen jedes Typs des DAG-Typs im angegebenen Zeitbereich
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
Korrelations-IDs aller DAG-Ausführungen
Korrelations-IDs aller DAG-Ausführungen, die im Zeitbereich aufgetreten sind (für alle DAG-Typen)
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
Protokolle einer DAG-Ausführung
Ruft Protokolle für eine bestimmte AirFlow-DAG-Ausführung unter Berücksichtigung der CorrelationId und des Zeitbereichs ab.
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
Fehlerprotokolle einer DAG-Ausführung
Ruft Fehlerprotokolle für eine bestimmte AirFlow-DAG-Ausführung unter Berücksichtigung der CorrelationId und des Zeitbereichs ab.
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
Feedback
https://aka.ms/ContentUserFeedback.
Bald verfügbar: Im Laufe des Jahres 2024 werden wir GitHub-Issues stufenweise als Feedbackmechanismus für Inhalte abbauen und durch ein neues Feedbacksystem ersetzen. Weitere Informationen finden Sie unterFeedback senden und anzeigen für