Fabric Data Factory의 Dataflows Gen2에 대한 공용 API 기능

Fabric Data Factory는 사용자가 데이터 흐름을 효율적으로 자동화하고 관리할 수 있는 강력한 API 집합을 제공합니다. 이러한 API를 사용하면 다양한 데이터 원본 및 서비스와 원활하게 통합할 수 있으므로 사용자가 프로그래밍 방식으로 데이터 워크플로를 만들고 업데이트하고 모니터링할 수 있습니다. API는 데이터 흐름 CRUD(만들기, 읽기, 업데이트 및 삭제), 예약 및 모니터링을 비롯한 광범위한 작업을 지원하므로 사용자가 데이터 통합 프로세스를 보다 쉽게 관리할 수 있습니다.

데이터 흐름에 대한 API 사용 사례

Fabric Data Factory의 데이터 흐름에 대한 API는 다음과 같은 다양한 시나리오에서 사용할 수 있습니다.

자동화된 배포: CI/CD 사례를 사용하여 다양한 환경(개발, 테스트, 프로덕션)에서 데이터 흐름의 배포를 자동화합니다.
모니터링 및 경고: 자동화된 모니터링 및 경고 시스템을 설정하여 데이터 흐름의 상태를 추적하고 오류 또는 성능 문제가 발생할 경우 알림을 받습니다.
데이터 통합: 데이터베이스, 데이터 레이크 및 클라우드 서비스와 같은 여러 원본의 데이터를 처리 및 분석을 위한 통합 데이터 흐름에 통합합니다.
오류 처리: 사용자 지정 오류 처리 및 재시도 메커니즘을 구현하여 데이터 흐름이 원활하게 실행되고 오류로부터 복구되도록 합니다.

API 이해

Fabric Data Factory의 데이터 흐름에 API를 효과적으로 사용하려면 주요 개념과 구성 요소를 이해해야 합니다.

엔드포인트: API 엔드포인트는 데이터 흐름 만들기, 업데이트 및 삭제와 같은 다양한 데이터 흐름 작업에 대한 액세스를 제공합니다.
인증: OAuth 또는 API 키와 같은 인증 메커니즘을 사용하여 API에 대한 액세스를 보호합니다.
요청 및 응답: 필요한 매개 변수 및 예상 출력을 포함하여 API 요청 및 응답의 구조를 이해합니다.
속도 제한: 허용된 요청 수를 초과하지 않도록 API 사용량에 적용되는 속도 제한을 알고 있어야 합니다.

CRUD 지원

CRUD는 데이터에서 수행할 수 있는 네 가지 기본 작업인 만들기, 읽기, 업데이트 및 삭제를 의미합니다. Fabric Data Factory에서 CRUD 작업은 Data Factory용 패브릭 API를 통해 지원됩니다. 이러한 API를 사용하면 사용자가 프로그래밍 방식으로 데이터 흐름을 관리할 수 있습니다. CRUD 지원에 대한 몇 가지 핵심 사항은 다음과 같습니다.

만들기: API를 사용하여 새 데이터 흐름을 만듭니다. 여기에는 데이터 흐름 구조를 정의하고 데이터 원본, 변환 및 대상을 지정하는 작업이 포함됩니다.
읽기: 기존 데이터 흐름에 대한 정보를 검색합니다. 여기에는 구성, 상태 및 실행 기록에 대한 세부 정보가 포함됩니다.
업데이트: 기존 데이터 흐름을 업데이트합니다. 여기에는 데이터 흐름 구조 수정, 데이터 원본 변경 또는 변환 논리 업데이트가 포함될 수 있습니다.
삭제: 더 이상 필요하지 않은 데이터 흐름을 삭제합니다. 이렇게 하면 리소스를 관리하고 정리하는 데 도움이 됩니다.

Microsoft Fabric REST API에 대한 기본 온라인 참조 설명서는 Microsoft Fabric REST API 설명서에서 찾을 수 있습니다.

데이터 흐름 수명 주기

데이터 흐름을 사용할 때는 데이터 흐름의 수명 주기를 이해하여 원활하고 효율적인 데이터 통합 프로세스를 보장하는 것이 중요합니다. 데이터 흐름 수명 주기의 주요 단계는 다음과 같습니다.

정의: 데이터 흐름의 정의를 만들거나 수정하는 초기 단계입니다. 여기에는 데이터 원본, 변환 및 정의를 지정하는 작업이 포함됩니다.
출판하다: 데이터 흐름의 정의를 수정한 후 게시 작업을 호출해야 합니다. 이는 데이터 흐름의 정의에 대한 변경 내용을 저장하고 실행에 사용할 수 있도록 하는 중요한 단계입니다.
리프레쉬: 데이터 흐름이 게시되면 새로 고침 작업을 호출할 수 있습니다. 이렇게 하면 데이터 흐름이 실행되고, 지정된 원본에서 데이터를 끌어오고, 정의된 변환을 적용하고, 대상에 데이터를 로드합니다.

데이터 흐름에 대한 공용 API 시작

이 섹션에서는 다음 항목을 모두 다룹니다.

권한 부여 토큰 가져오기
데이터 흐름 만들기
정의를 사용하여 데이터 흐름 만들기
데이터 흐름 가져오기
정의를 사용하여 데이터 흐름 가져오기
데이터 흐름 업데이트
정의를 사용하여 데이터 흐름 업데이트
데이터 흐름 삭제
주문형 데이터 흐름 작업 실행(새로 고침)
주문형 데이터 흐름 게시 작업 실행
데이터 흐름 작업 인스턴스 가져오기
데이터 흐름 작업 인스턴스 취소

권한 부여 토큰 가져오기

모든 REST API 호출에 대한 전달자 토큰이 있어야 하며 다음 옵션 중 하나를 사용하여 가져올 수 있습니다.

MSAL.Net
패브릭 포털

MSAL.Net

Fabric API 빠른 시작 - Microsoft Fabric REST API

MSAL.Net을 사용하여 Fabric 서비스에 대한 Microsoft Entra ID 토큰을 획득하기 위해 다음 범위인 Workspace.ReadWrite.All 및 Item.ReadWrite.All을 사용합니다. MSAL.Net을 사용하여 토큰을 획득하는 방법에 대한 자세한 내용은 토큰 획득 - .NET용 Microsoft 인증 라이브러리를 참조하세요.

이전에 복사한 애플리케이션(클라이언트) ID를 붙여넣고 ClientId 변수에 붙여넣습니다.

패브릭 포털

테스트할 테넌트의 패브릭 포털에 로그인하고 F12 키를 눌러 브라우저의 개발자 모드로 전환합니다. 콘솔에서 다음을 실행합니다.

powerBIAccessToken

토큰을 복사하여 ClientId 변수에 붙여넣습니다.

데이터 흐름 만들기

지정된 작업 영역에서 데이터 흐름을 만듭니다.

샘플 요청

URI: POST [https://api.fabric.microsoft.com/v1/workspaces/{workspaceId}/items](https://api.fabric.microsoft.com/v1/workspaces/%7bworkspaceId%7d/items)

Headers:

{
    "Authorization": "\<bearer-token>",
    "Content-Type": "application/json"
}

Payload:

{
    "displayName": "My dataflow",
    "description": "My dataflow description",
    "type": "Dataflow"
}

샘플 응답

{
    "id": "\<itemId>",
    "type": "Dataflow",
    "displayName": "My dataflow",
    "description": "My dataflow description",
    "workspaceId": "\<workspaceId>"
}

정의를 사용하여 데이터 흐름 만들기

지정된 작업 영역에서 base64 정의를 사용하여 데이터 흐름을 만듭니다.

샘플 매시업 문서

{
    "editingSessionMashup": {
            "mashupName": "",
            "mashupDocument": "section Section1;\r\nshared Query = let\n Source = Table.FromRows(\n {\n {1, \"Bob\", \"123-4567\"},\n {2, \"Jim\", \"987-6543\"}\n },\n {\"CustomerID\", \"Name\", \"Phone\"})\nin\n Source;\r\n",
            "queryGroups": [],
            "documentLocale": "en-US",
            "gatewayObjectId": null,
            "queriesMetadata": null,
            "connectionOverrides": [],
            "trustedConnections": null,
            "useHostConnectionProvider": false,
            "fastCombine": false,
            "allowNativeQueries": true,
            "allowedModules": null,
            "skipAutomaticTypeAndHeaderDetection": false,
            "disableAutoAnonymousConnectionUpsert": null,
            "hostProperties": {
                    "DataflowRefreshOutputFileFormat": "Parquet",
                    "EnableDateTimeFieldsForStaging": "true",
                    "EnablePublishWithoutLoadedQueries": "true"
            },
            "defaultOutputDestinationConfiguration": null,
            "stagingDefinition": null
    }
}

Base64 인코딩 및 디코딩을 사용하여 JSON을 인코딩합니다.

URL 안전 인코딩 수행 상자가 선택되어 있지 않은지 확인합니다.

인코딩된 Base64 요청 페이로드의 응답을 페이로드 정의에 붙여넣습니다.

샘플 요청

URI: POST [https://api.fabric.microsoft.com/v1/workspaces/{workspaceId}/items](https://api.fabric.microsoft.com/v1/workspaces/%7bworkspaceId%7d/items)

Headers:

{
    "Authorization": "\<bearer-token>",
    "Content-Type": "application/json"
}

Payload:

{
    "displayName": " My dataflow",
    "description": "My dataflow description",

    "type": "Dataflow",
    "definition": {  
        "parts": [  
            {  
                "path": "dataflow-content.json",  
                "payload": "ewogICAgImVkaXRpbmdTZXNzaW9uTWFzaHVwIjogewogICAgICAgICJtYXNodXBOYW1lIjogIiIsCiAgICAgICAgIm1hc2h1cERvY3VtZW50IjogInNlY3Rpb24gU2VjdGlvbjE7XHJcbnNoYXJlZCBRdWVyeSA9IGxldFxuIFNvdXJjZSA9IFRhYmxlLkZyb21Sb3dzKFxuIHtcbiB7MSwgXCJCb2JcIiwgXCIxMjMtNDU2N1wifSxcbiB7MiwgXCJKaW1cIiwgXCI5ODctNjU0M1wifVxuIH0sXG4ge1wiQ3VzdG9tZXJJRFwiLCBcIk5hbWVcIiwgXCJQaG9uZVwifSlcbmluXG4gU291cmNlO1xyXG4iLAogICAgICAgICJxdWVyeUdyb3VwcyI6IFtdLAogICAgICAgICJkb2N1bWVudExvY2FsZSI6ICJlbi1VUyIsCiAgICAgICAgImdhdGV3YXlPYmplY3RJZCI6IG51bGwsCiAgICAgICAgInF1ZXJpZXNNZXRhZGF0YSI6IG51bGwsCiAgICAgICAgImNvbm5lY3Rpb25PdmVycmlkZXMiOiBbXSwKICAgICAgICAidHJ1c3RlZENvbm5lY3Rpb25zIjogbnVsbCwKICAgICAgICAidXNlSG9zdENvbm5lY3Rpb25Qcm92aWRlciI6IGZhbHNlLAogICAgICAgICJmYXN0Q29tYmluZSI6IGZhbHNlLAogICAgICAgICJhbGxvd05hdGl2ZVF1ZXJpZXMiOiB0cnVlLAogICAgICAgICJhbGxvd2VkTW9kdWxlcyI6IG51bGwsCiAgICAgICAgInNraXBBdXRvbWF0aWNUeXBlQW5kSGVhZGVyRGV0ZWN0aW9uIjogZmFsc2UsCiAgICAgICAgImRpc2FibGVBdXRvQW5vbnltb3VzQ29ubmVjdGlvblVwc2VydCI6IG51bGwsCiAgICAgICAgImhvc3RQcm9wZXJ0aWVzIjogewogICAgICAgICAgICAiRGF0YWZsb3dSZWZyZXNoT3V0cHV0RmlsZUZvcm1hdCI6ICJQYXJxdWV0IiwKICAgICAgICAgICAgIkVuYWJsZURhdGVUaW1lRmllbGRzRm9yU3RhZ2luZyI6ICJ0cnVlIiwKICAgICAgICAgICAgIkVuYWJsZVB1Ymxpc2hXaXRob3V0TG9hZGVkUXVlcmllcyI6ICJ0cnVlIgogICAgICAgIH0sCiAgICAgICAgImRlZmF1bHRPdXRwdXREZXN0aW5hdGlvbkNvbmZpZ3VyYXRpb24iOiBudWxsLAogICAgICAgICJzdGFnaW5nRGVmaW5pdGlvbiI6IG51bGwKICAgIH0KfQ==",
                "payloadType": "InlineBase64"  
            }  
        ]  
    }  
}

샘플 응답

{
    "id": "\<itemId>",
    "type": "Dataflow",
    "displayName": "My dataflow",
    "description": "My dataflow description",
    "workspaceId": "\<workspaceId>"
}

데이터 흐름 가져오기

지정된 데이터 흐름의 속성을 반환합니다.

샘플 요청

URI: GET [https://api.fabric.microsoft.com/v1/workspaces/{workspaceId}/items/{itemId}](https://api.fabric.microsoft.com/v1/workspaces/%7bworkspaceId%7d/items/%7bitemId%7d)

Headers:

{
    "Authorization": "\<bearer-token>"
}

샘플 응답

{
    "id": "\<itemId>",
    "type": "Dataflow",
    "displayName": "My dataflow",
    "description": "My dataflow description",
    "workspaceId": "\<workspaceId>"
}

정의를 사용하여 데이터 흐름 가져오기

데이터 흐름 항목 정의를 반환합니다.

샘플 요청

URI: POST [https://api.fabric.microsoft.com/v1/workspaces/{workspaceId}/items/{itemId}/getDefinition](https://api.fabric.microsoft.com/v1/workspaces/%7bworkspaceId%7d/items/%7bitemId%7d/getDefinition)

Headers:

{
    "Authorization": "\<bearer-token>"
}

샘플 응답

{ 

    "definition": { 

        "parts": [ 

            { 

                "path": "dataflow-content.json", 

                "payload": " ewogICAgImVkaXRpbmdTZXNzaW9uTWFzaHVwIjogewogICAgICAgICJtYXNodXBOYW1lIjogIiIsCiAgICAgICAgIm1hc2h1cERvY3VtZW50IjogInNlY3Rpb24gU2VjdGlvbjE7XHJcbnNoYXJlZCBRdWVyeSA9IGxldFxuIFNvdXJjZSA9IFRhYmxlLkZyb21Sb3dzKFxuIHtcbiB7MSwgXCJCb2JcIiwgXCIxMjMtNDU2N1wifSxcbiB7MiwgXCJKaW1cIiwgXCI5ODctNjU0M1wifVxuIH0sXG4ge1wiQ3VzdG9tZXJJRFwiLCBcIk5hbWVcIiwgXCJQaG9uZVwifSlcbmluXG4gU291cmNlO1xyXG4iLAogICAgICAgICJxdWVyeUdyb3VwcyI6IFtdLAogICAgICAgICJkb2N1bWVudExvY2FsZSI6ICJlbi1VUyIsCiAgICAgICAgImdhdGV3YXlPYmplY3RJZCI6IG51bGwsCiAgICAgICAgInF1ZXJpZXNNZXRhZGF0YSI6IG51bGwsCiAgICAgICAgImNvbm5lY3Rpb25PdmVycmlkZXMiOiBbXSwKICAgICAgICAidHJ1c3RlZENvbm5lY3Rpb25zIjogbnVsbCwKICAgICAgICAidXNlSG9zdENvbm5lY3Rpb25Qcm92aWRlciI6IGZhbHNlLAogICAgICAgICJmYXN0Q29tYmluZSI6IGZhbHNlLAogICAgICAgICJhbGxvd05hdGl2ZVF1ZXJpZXMiOiB0cnVlLAogICAgICAgICJhbGxvd2VkTW9kdWxlcyI6IG51bGwsCiAgICAgICAgInNraXBBdXRvbWF0aWNUeXBlQW5kSGVhZGVyRGV0ZWN0aW9uIjogZmFsc2UsCiAgICAgICAgImRpc2FibGVBdXRvQW5vbnltb3VzQ29ubmVjdGlvblVwc2VydCI6IG51bGwsCiAgICAgICAgImhvc3RQcm9wZXJ0aWVzIjogewogICAgICAgICAgICAiRGF0YWZsb3dSZWZyZXNoT3V0cHV0RmlsZUZvcm1hdCI6ICJQYXJxdWV0IiwKICAgICAgICAgICAgIkVuYWJsZURhdGVUaW1lRmllbGRzRm9yU3RhZ2luZyI6ICJ0cnVlIiwKICAgICAgICAgICAgIkVuYWJsZVB1Ymxpc2hXaXRob3V0TG9hZGVkUXVlcmllcyI6ICJ0cnVlIgogICAgICAgIH0sCiAgICAgICAgImRlZmF1bHRPdXRwdXREZXN0aW5hdGlvbkNvbmZpZ3VyYXRpb24iOiBudWxsLAogICAgICAgICJzdGFnaW5nRGVmaW5pdGlvbiI6IG51bGwKICAgIH0KfQ==" 

                "payloadType": "InlineBase64" 

            }, 

            { 

                "path": ".platform", 

                "payload": "ewogICIkc2NoZW1hIjogImh0dHBzOi8vZGV2ZWxvcGVyLm1pY3Jvc29mdC5jb20vanNvbi1zY2hlbWFzL2ZhYnJpYy9naXRJbnRlZ3JhdGlvbi9wbGF0Zm9ybVByb3BlcnRpZXMvMi4wLjAvc2NoZW1hLmpzb24iLAogICJtZXRhZGF0YSI6IHsKICAgICJ0eXBlIjogIkRhdGFmbG93IiwKICAgICJkaXNwbGF5TmFtZSI6ICJEYXRhZmxvdyAzIgogIH0sCiAgImNvbmZpZyI6IHsKICAgICJ2ZXJzaW9uIjogIjIuMCIsCiAgICAibG9naWNhbElkIjogIjAwMDAwMDAwLTAwMDAtMDAwMC0wMDAwLTAwMDAwMDAwMDAwMCIKICB9Cn0=", 

                "payloadType": "InlineBase64" 

            } 

        ] 

    } 

}

API의 응답

{ 
    'definition':  
    { 
        'parts': [ 
            { 
                'path': 'queryMetadata.json', 'payload': '<super long entry>', 'payloadType': 'InlineBase64' 
            }, 
            { 
                'path': 'mashup.pq', 'payload': '<super long entry>', 'payloadType': 'InlineBase64' 
            }, 
            { 
                'path': '.platform', 'payload': '<super long entry>', 'payloadType': 'InlineBase64' 
            } 
        ] 
    } 
}

데이터 흐름 업데이트

데이터 흐름의 속성을 업데이트합니다.

샘플 요청

URI: PATCH [https://api.fabric.microsoft.com/v1/workspaces/{workspaceId}/items/{itemId}](https://api.fabric.microsoft.com/v1/workspaces/%7bworkspaceId%7d/items/%7bitemId%7d)  

Headers: 

{ 
  "Authorization": "\<bearer-token>", 
  "Content-Type": "application/json" 
} 

Payload: 
{ 
  "displayName": "My dataflow updated", 
  "description": "My dataflow description updated", 
  "type": "Dataflow" 
}

샘플 응답

{ 
    "id": "\<itemId>", 
    "type": "Dataflow", 
    "displayName": "My dataflow updated", 
    "description": "My dataflow description updated", 
    "workspaceId": "\<workspaceId>" 
}

정의를 사용하여 데이터 흐름 업데이트

데이터 흐름 항목 정의를 업데이트합니다.

샘플 요청

URI: POST [https://api.fabric.microsoft.com/v1/workspaces/{workspaceId}/items/{itemId}/updateDefinition](https://api.fabric.microsoft.com/v1/workspaces/%7bworkspaceId%7d/items/%7bitemId%7d/updateDefinition) 

Headers: 

{ 
  "Authorization": "\<bearer-token>", 
  "Content-Type": "application/json" 
} 

Payload: 

{ 
  "displayName": " My dataflow", 
  "type": "Dataflow", 
  "definition": { 
    "parts": [  
      {  
        "path": "dataflow-content.json",  
        "payload": " ewogICAgImVkaXRpbmdTZXNzaW9uTWFzaHVwIjogewogICAgICAgICJtYXNodXBOYW1lIjogIiIsCiAgICAgICAgIm1hc2h1cERvY3VtZW50IjogInNlY3Rpb24gU2VjdGlvbjE7XHJcbnNoYXJlZCBRdWVyeSA9IGxldFxuIFNvdXJjZSA9IFRhYmxlLkZyb21Sb3dzKFxuIHtcbiB7MSwgXCJCb2JcIiwgXCIxMjMtNDU2N1wifSxcbiB7MiwgXCJKaW1cIiwgXCI5ODctNjU0M1wifVxuIH0sXG4ge1wiQ3VzdG9tZXJJRFwiLCBcIk5hbWVcIiwgXCJQaG9uZVwifSlcbmluXG4gU291cmNlO1xyXG4iLAogICAgICAgICJxdWVyeUdyb3VwcyI6IFtdLAogICAgICAgICJkb2N1bWVudExvY2FsZSI6ICJlbi1VUyIsCiAgICAgICAgImdhdGV3YXlPYmplY3RJZCI6IG51bGwsCiAgICAgICAgInF1ZXJpZXNNZXRhZGF0YSI6IG51bGwsCiAgICAgICAgImNvbm5lY3Rpb25PdmVycmlkZXMiOiBbXSwKICAgICAgICAidHJ1c3RlZENvbm5lY3Rpb25zIjogbnVsbCwKICAgICAgICAidXNlSG9zdENvbm5lY3Rpb25Qcm92aWRlciI6IGZhbHNlLAogICAgICAgICJmYXN0Q29tYmluZSI6IGZhbHNlLAogICAgICAgICJhbGxvd05hdGl2ZVF1ZXJpZXMiOiB0cnVlLAogICAgICAgICJhbGxvd2VkTW9kdWxlcyI6IG51bGwsCiAgICAgICAgInNraXBBdXRvbWF0aWNUeXBlQW5kSGVhZGVyRGV0ZWN0aW9uIjogZmFsc2UsCiAgICAgICAgImRpc2FibGVBdXRvQW5vbnltb3VzQ29ubmVjdGlvblVwc2VydCI6IG51bGwsCiAgICAgICAgImhvc3RQcm9wZXJ0aWVzIjogewogICAgICAgICAgICAiRGF0YWZsb3dSZWZyZXNoT3V0cHV0RmlsZUZvcm1hdCI6ICJQYXJxdWV0IiwKICAgICAgICAgICAgIkVuYWJsZURhdGVUaW1lRmllbGRzRm9yU3RhZ2luZyI6ICJ0cnVlIiwKICAgICAgICAgICAgIkVuYWJsZVB1Ymxpc2hXaXRob3V0TG9hZGVkUXVlcmllcyI6ICJ0cnVlIgogICAgICAgIH0sCiAgICAgICAgImRlZmF1bHRPdXRwdXREZXN0aW5hdGlvbkNvbmZpZ3VyYXRpb24iOiBudWxsLAogICAgICAgICJzdGFnaW5nRGVmaW5pdGlvbiI6IG51bGwKICAgIH0KfQ==",  
        "payloadType": "InlineBase64"  
      } 
    ] 
  } 
}

샘플 응답

200 OK

데이터 흐름 삭제

지정된 데이터 흐름을 삭제합니다.

샘플 요청

URI: DELETE [https://api.fabric.microsoft.com/v1/workspaces/{workspaceId}/items/{itemId}](https://api.fabric.microsoft.com/v1/workspaces/%7bworkspaceId%7d/items/%7bitemId%7d)  

Headers: 

{ 
  "Authorization": "\<bearer-token>" 
}

샘플 응답

200 OK

주문형 데이터 흐름 작업 실행(새로 고침)

새로 고침 인스턴스에 대한 주문형 데이터 흐름 작업을 실행합니다.

샘플 요청

URI: POST [https://api.fabric.microsoft.com/v1/workspaces/{workspaceId}/items/{itemId}/jobs/instances?jobType=Refresh](https://api.fabric.microsoft.com/v1/workspaces/%7bworkspaceId%7d/items/%7bitemId%7d/jobs/instances?jobType=Refresh)  

Headers: 

{ 
  "Authorization": "\<bearer-token>" 
} 

Payload: 

{ 
    "executionData": { 
        "DataflowName": "Dataflow", 
        "OwnerUserPrincipalName": "\<name@email.com>", 
        "OwnerUserObjectId": "\<ObjectId>" 
    } 
}

샘플 응답

202 Accepted 
[ 
  { 
    "id": "\<jobId>", 
    "itemId": "\<dataflowItemId>", 
    "jobType": "Refresh", 
    "invokeType": "OnDemand", 
    "status": "Accepted", 
    "jobInstanceId": "\<uniqueJobInstanceId>", 
    "rootActivityId": "\<rootActivityId>", 
    "startTimeUtc": "2025-01-30T11:10:50Z", 
    "endTimeUtc": null, 
    "failureReason": null 
  } 
]

주문형 데이터 흐름 게시 작업 실행

게시 인스턴스에 대한 주문형 데이터 흐름 작업을 실행합니다.

샘플 요청

URI: POST [https://api.fabric.microsoft.com/v1/workspaces/{workspaceId}/items/{itemId}/jobs/instances?jobType=Publish](https://api.fabric.microsoft.com/v1/workspaces/%7bworkspaceId%7d/items/%7bitemId%7d/jobs/instances?jobType=Publish) 

Headers: 

{ 
  "Authorization": "\<bearer-token>" 
} 

Payload: 

{ 
    "executionData": { 
        "DataflowName": "Dataflow", 
        "OwnerUserPrincipalName": "\<name@email.com>", 
        "OwnerUserObjectId": "\<ObjectId>" 
    }
}

샘플 응답

202 Accepted 

[ 
  { 
    "id": "\<jobId>", 
    "itemId": "\<dataflowItemId>", 
    "jobType": "Publish", 
    "invokeType": "OnDemand", 
    "status": "Accepted", 
    "jobInstanceId": "\<uniqueJobInstanceId>", 
    "rootActivityId": "\<rootActivityId>", 
    "startTimeUtc": "2025-01-30T11:10:50Z", 
    "endTimeUtc": null, 
    "failureReason": null 
  } 
]

데이터 흐름 작업 인스턴스 가져오기

단일 데이터 흐름의 작업 인스턴스를 가져옵니다.

샘플 요청

URI: GET [https://api.fabric.microsoft.com/v1/workspaces/{workspaceId}/items/{itemId}/jobs/instances/{jobInstanceId}](https://api.fabric.microsoft.com/v1/workspaces/%7bworkspaceId%7d/items/%7bitemId%7d/jobs/instances/%7bjobInstanceId%7d)  

Headers: 

{ 
  "Authorization": "\<bearer-token>" 
}

샘플 응답

{ 
  "id": "\<id>", 
  "itemId": "<itemId?", 
  "jobType": "Refresh", 
  "invokeType": "Manual", 
  "status": "Completed", 
  "rootActivityId": "\<rootActivityId>", 
  "startTimeUtc": "2023-08-22T06:35:00.7812154", 
  "endTimeUtc": "2023-08-22T06:35:00.8033333", 
  "failureReason": null 
}

데이터 흐름 작업 인스턴스 취소

데이터 흐름의 작업 인스턴스 취소

샘플 요청

URI: POST [https://api.fabric.microsoft.com/v1/workspaces/{workspaceId}/items/{itemId}/jobs/instances/{jobInstanceId}/cancel](https://api.fabric.microsoft.com/v1/workspaces/%7bworkspaceId%7d/items/%7bitemId%7d/jobs/instances/%7bjobInstanceId%7d/cancel)  

Headers: 

{ 
  "Authorization": "\<bearer-token>"
}

샘플 응답

Location: https://api.fabric.microsoft.com/v1/workspaces/\<worksapceId>/items/\<itemId>/jobs/instances/\<jobInstanceId> 

Retry-After: 60

현재 제한 사항

서비스 주체 인증 은 현재 지원되지 않습니다.
데이터 흐름 항목 유형을 필터링하는 경우 "항목 가져오기" 및 "항목 액세스 세부 정보 나열"은 올바른 정보를 반환하지 않습니다.
형식을 지정하지 않으면 CI/CD 및 GIT 지원을 사용하는 새 Dataflow Gen2인 Dataflow Gen2(CI/CD, 미리 보기) 를 반환합니다.
실행 API 는 호출할 수 있지만 실제 실행은 성공하지 않습니다.

다음을 통해 공유

Fabric Data Factory의 Dataflows Gen2에 대한 공용 API 기능

데이터 흐름에 대한 API 사용 사례

API 이해

CRUD 지원

데이터 흐름 수명 주기

데이터 흐름에 대한 공용 API 시작

권한 부여 토큰 가져오기

MSAL.Net

패브릭 포털

데이터 흐름 만들기

정의를 사용하여 데이터 흐름 만들기

데이터 흐름 가져오기

정의를 사용하여 데이터 흐름 가져오기

데이터 흐름 업데이트

정의를 사용하여 데이터 흐름 업데이트

데이터 흐름 삭제

주문형 데이터 흐름 작업 실행(새로 고침)

주문형 데이터 흐름 게시 작업 실행

데이터 흐름 작업 인스턴스 가져오기

데이터 흐름 작업 인스턴스 취소

현재 제한 사항

관련 콘텐츠

문서

튜토리얼

피드백

추가 리소스