Freigeben über


Activity Runs - Query By Pipeline Run

Abfrageaktivität wird basierend auf Eingabefilterbedingungen ausgeführt.

POST https://management.azure.com/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/pipelineruns/{runId}/queryActivityruns?api-version=2018-06-01

URI-Parameter

Name In Erforderlich Typ Beschreibung
factoryName
path True

string

minLength: 3
maxLength: 63
pattern: ^[A-Za-z0-9]+(?:-[A-Za-z0-9]+)*$

Der Werksname.

resourceGroupName
path True

string

minLength: 1
maxLength: 90
pattern: ^[-\w\._\(\)]+$

Der Ressourcengruppenname.

runId
path True

string

Der Pipelineausführungsbezeichner.

subscriptionId
path True

string

Der Abonnementbezeichner.

api-version
query True

string

Die API-Version.

Anforderungstext

Name Erforderlich Typ Beschreibung
lastUpdatedAfter True

string (date-time)

Die Uhrzeit, zu der bzw. nach der das Ausführungsereignis im ISO 8601-Format aktualisiert wurde.

lastUpdatedBefore True

string (date-time)

Die Uhrzeit, zu der bzw. vor der das Ausführungsereignis im ISO 8601-Format aktualisiert wurde.

continuationToken

string

Das Fortsetzungstoken zum Abrufen der nächsten Seite mit Ergebnissen. Null für die erste Seite.

filters

RunQueryFilter[]

Liste der Filter.

orderBy

RunQueryOrderBy[]

Liste der Option "OrderBy".

Antworten

Name Typ Beschreibung
200 OK

ActivityRunsQueryResponse

OKAY.

Other Status Codes

CloudError

Eine Fehlerantwort, die vom Azure Data Factory-Dienst empfangen wurde.

Sicherheit

azure_auth

Azure Active Directory OAuth2-Fluss.

Typ: oauth2
Ablauf: implicit
Autorisierungs-URL: https://login.microsoftonline.com/common/oauth2/authorize

Bereiche

Name Beschreibung
user_impersonation Identitätswechsel ihres Benutzerkontos

Beispiele

ActivityRuns_QueryByPipelineRun

Beispielanforderung

POST https://management.azure.com/subscriptions/12345678-1234-1234-1234-12345678abc/resourceGroups/exampleResourceGroup/providers/Microsoft.DataFactory/factories/exampleFactoryName/pipelineruns/2f7fdb90-5df1-4b8e-ac2f-064cfa58202b/queryActivityruns?api-version=2018-06-01

{
  "lastUpdatedAfter": "2018-06-16T00:36:44.3345758Z",
  "lastUpdatedBefore": "2018-06-16T00:49:48.3686473Z"
}

Beispiel für eine Antwort

Date: Sat, 16 Jun 2018 00:40:13 GMT
X-Content-Type-Options: nosniff
x-ms-ratelimit-remaining-subscription-writes: 1187
x-ms-request-id: 5465cf41-2e71-4ce6-8db4-9de1b92ffda9
x-ms-correlation-request-id: 5465cf41-2e71-4ce6-8db4-9de1b92ffda9
{
  "value": [
    {
      "activityRunEnd": "2018-06-16T00:38:11.5445431Z",
      "activityName": "ExampleForeachActivity",
      "activityRunStart": "2018-06-16T00:37:49.4804925Z",
      "activityType": "ForEach",
      "durationInMs": 22064,
      "retryAttempt": null,
      "error": {
        "errorCode": "",
        "message": "",
        "failureType": "",
        "target": "ExampleForeachActivity"
      },
      "activityRunId": "f30c5514-fb85-43ed-9fa4-768d42e58680",
      "input": {},
      "linkedServiceName": "",
      "output": {},
      "userProperties": {},
      "pipelineName": "examplePipeline",
      "pipelineRunId": "2f7fdb90-5df1-4b8e-ac2f-064cfa58202b",
      "status": "Succeeded"
    },
    {
      "activityRunEnd": "2018-06-16T00:38:07.4188923Z",
      "activityName": "ExampleCopyActivity",
      "activityRunStart": "2018-06-16T00:37:50.2460952Z",
      "activityType": "Copy",
      "durationInMs": 17172,
      "retryAttempt": null,
      "error": {
        "errorCode": "",
        "message": "",
        "failureType": "",
        "target": "ExampleCopyActivity"
      },
      "activityRunId": "a96678c8-7167-4f00-b629-afccfbad4e51",
      "input": {
        "source": {
          "type": "BlobSource"
        },
        "sink": {
          "type": "BlobSink"
        },
        "dataIntegrationUnits": 32
      },
      "linkedServiceName": "",
      "output": {
        "dataRead": 142000,
        "dataWritten": 142000,
        "filesRead": 1,
        "filesWritten": 1,
        "copyDuration": 6,
        "throughput": 23.112,
        "errors": [],
        "effectiveIntegrationRuntime": "DefaultIntegrationRuntime (East US)",
        "usedCloudDataMovementUnits": 4,
        "usedParallelCopies": 1,
        "executionDetails": [
          {
            "source": {
              "type": "AzureBlob"
            },
            "sink": {
              "type": "AzureBlob"
            },
            "status": "Succeeded",
            "start": "2018-06-16T00:37:50.68834Z",
            "duration": 6,
            "usedCloudDataMovementUnits": 4,
            "usedParallelCopies": 1,
            "detailedDurations": {
              "queuingDuration": 4,
              "transferDuration": 2
            }
          }
        ]
      },
      "userProperties": {},
      "pipelineName": "examplePipeline",
      "pipelineRunId": "2f7fdb90-5df1-4b8e-ac2f-064cfa58202b",
      "status": "Succeeded"
    }
  ]
}

Definitionen

Name Beschreibung
ActivityRun

Informationen zu einer Aktivität, die in einer Pipeline ausgeführt wird.

ActivityRunsQueryResponse

Eine Listenaktivität wird ausgeführt.

CloudError

Das Objekt, das die Struktur einer Azure Data Factory-Fehlerantwort definiert.

RunFilterParameters

Abfrageparameter für auflistungsausführungen.

RunQueryFilter

Abfragefilteroption für Die Auflistung wird ausgeführt.

RunQueryFilterOperand

Parametername, der für den Filter verwendet werden soll. Die zulässigen Operanden für die Abfragepipeline sind PipelineName, RunStart, RunEnd und Status; zur Abfrageaktivitätsausführung sind ActivityName, ActivityRunStart, ActivityRunEnd, ActivityType und Status sowie abfragetriggerausführungen Triggername, TriggerRunTimestamp und Status.

RunQueryFilterOperator

Operator, der für den Filter verwendet werden soll.

RunQueryOrder

Sortierreihenfolge des Parameters.

RunQueryOrderBy

Ein Objekt, das die Reihenfolge nach Optionen zum Auflisten von Ausführungsläufen bereitstellt.

RunQueryOrderByField

Parametername, der für die Reihenfolge verwendet werden soll. Die zulässigen Parameter für pipelineausführungen sind PipelineName, RunStart, RunEnd und Status; für Aktivitätsläufe sind ActivityName, ActivityRunStart, ActivityRunEnd und Status; für Triggerläufe sind TriggerName, TriggerRunTimestamp und Status.

ActivityRun

Informationen zu einer Aktivität, die in einer Pipeline ausgeführt wird.

Name Typ Beschreibung
activityName

string

Der Name der Aktivität.

activityRunEnd

string (date-time)

Die Endzeit der Aktivität, die im ISO 8601-Format ausgeführt wird.

activityRunId

string

Die ID der Aktivitätsausführung.

activityRunStart

string (date-time)

Die Startzeit der Aktivität im ISO 8601-Format.

activityType

string

Der Typ der Aktivität.

durationInMs

integer

Die Dauer der Ausführung der Aktivität.

error

object

Der Fehler, wenn eine der Aktivitäten ausgeführt wird.

input

object

Die Eingabe für die Aktivität.

linkedServiceName

string

Der Name des compute-verknüpften Diensts.

output

object

Die Ausgabe für die Aktivität.

pipelineName

string

Der Name der Pipeline.

pipelineRunId

string

Die ID der Pipelineausführung.

status

string

Der Status der Aktivitätsausführung.

ActivityRunsQueryResponse

Eine Listenaktivität wird ausgeführt.

Name Typ Beschreibung
continuationToken

string

Das Fortsetzungstoken zum Abrufen der nächsten Seite mit Ergebnissen, wenn verbleibende Ergebnisse vorhanden sind, andernfalls NULL.

value

ActivityRun[]

Liste der Aktivitätsausführungen.

CloudError

Das Objekt, das die Struktur einer Azure Data Factory-Fehlerantwort definiert.

Name Typ Beschreibung
error.code

string

Fehlercode.

error.details

CloudError[]

Array mit zusätzlichen Fehlerdetails.

error.message

string

Fehlermeldung.

error.target

string

Eigenschaftsname/Pfad in Anforderung, die fehler zugeordnet ist.

RunFilterParameters

Abfrageparameter für auflistungsausführungen.

Name Typ Beschreibung
continuationToken

string

Das Fortsetzungstoken zum Abrufen der nächsten Seite mit Ergebnissen. Null für die erste Seite.

filters

RunQueryFilter[]

Liste der Filter.

lastUpdatedAfter

string (date-time)

Die Uhrzeit, zu der bzw. nach der das Ausführungsereignis im ISO 8601-Format aktualisiert wurde.

lastUpdatedBefore

string (date-time)

Die Uhrzeit, zu der bzw. vor der das Ausführungsereignis im ISO 8601-Format aktualisiert wurde.

orderBy

RunQueryOrderBy[]

Liste der Option "OrderBy".

RunQueryFilter

Abfragefilteroption für Die Auflistung wird ausgeführt.

Name Typ Beschreibung
operand

RunQueryFilterOperand

Parametername, der für den Filter verwendet werden soll. Die zulässigen Operanden für die Abfragepipeline sind PipelineName, RunStart, RunEnd und Status; zur Abfrageaktivitätsausführung sind ActivityName, ActivityRunStart, ActivityRunEnd, ActivityType und Status sowie abfragetriggerausführungen Triggername, TriggerRunTimestamp und Status.

operator

RunQueryFilterOperator

Operator, der für den Filter verwendet werden soll.

values

string[]

Liste der Filterwerte.

RunQueryFilterOperand

Parametername, der für den Filter verwendet werden soll. Die zulässigen Operanden für die Abfragepipeline sind PipelineName, RunStart, RunEnd und Status; zur Abfrageaktivitätsausführung sind ActivityName, ActivityRunStart, ActivityRunEnd, ActivityType und Status sowie abfragetriggerausführungen Triggername, TriggerRunTimestamp und Status.

Wert Beschreibung
ActivityName
ActivityRunEnd
ActivityRunStart
ActivityType
LatestOnly
PipelineName
RunEnd
RunGroupId
RunStart
Status
TriggerName
TriggerRunTimestamp

RunQueryFilterOperator

Operator, der für den Filter verwendet werden soll.

Wert Beschreibung
Equals
In
NotEquals
NotIn

RunQueryOrder

Sortierreihenfolge des Parameters.

Wert Beschreibung
ASC
DESC

RunQueryOrderBy

Ein Objekt, das die Reihenfolge nach Optionen zum Auflisten von Ausführungsläufen bereitstellt.

Name Typ Beschreibung
order

RunQueryOrder

Sortierreihenfolge des Parameters.

orderBy

RunQueryOrderByField

Parametername, der für die Reihenfolge verwendet werden soll. Die zulässigen Parameter für pipelineausführungen sind PipelineName, RunStart, RunEnd und Status; für Aktivitätsläufe sind ActivityName, ActivityRunStart, ActivityRunEnd und Status; für Triggerläufe sind TriggerName, TriggerRunTimestamp und Status.

RunQueryOrderByField

Parametername, der für die Reihenfolge verwendet werden soll. Die zulässigen Parameter für pipelineausführungen sind PipelineName, RunStart, RunEnd und Status; für Aktivitätsläufe sind ActivityName, ActivityRunStart, ActivityRunEnd und Status; für Triggerläufe sind TriggerName, TriggerRunTimestamp und Status.

Wert Beschreibung
ActivityName
ActivityRunEnd
ActivityRunStart
PipelineName
RunEnd
RunStart
Status
TriggerName
TriggerRunTimestamp