แชร์ผ่าน

ความสามารถของ API สาธารณะสําหรับกระแสข้อมูล Gen2 ใน Fabric Data Factory

Fabric Data Factory มีชุด API ที่มีประสิทธิภาพซึ่งช่วยให้ผู้ใช้สามารถทํางานโดยอัตโนมัติและจัดการกระแสข้อมูลได้อย่างมีประสิทธิภาพ API เหล่านี้ช่วยให้สามารถรวมกับแหล่งข้อมูลและบริการต่าง ๆ ได้อย่างราบรื่น ช่วยให้ผู้ใช้สามารถสร้าง อัปเดต และตรวจสอบเวิร์กโฟลว์ข้อมูลของพวกเขาได้โดยทางโปรแกรม API สนับสนุนการดําเนินงานที่หลากหลาย รวมถึง CRUD ของกระแสข้อมูล (สร้าง อ่าน อัปเดต และลบ) การจัดกําหนดการ และการตรวจสอบ ทําให้ผู้ใช้สามารถจัดการกระบวนการรวมข้อมูลได้ง่ายขึ้น

กรณีการใช้งาน API สําหรับกระแสข้อมูล

API สําหรับกระแสข้อมูลใน Fabric Data Factory สามารถใช้ในสถานการณ์ต่าง ๆ ได้:

  • การปรับใช้แบบอัตโนมัติ: ทําให้การปรับใช้กระแสข้อมูลในสภาพแวดล้อมที่แตกต่างกันเป็นแบบอัตโนมัติ (การพัฒนา การทดสอบ การผลิต) โดยใช้แนวทางปฏิบัติ CI/CD
  • การตรวจสอบและการแจ้งเตือน: ตั้งค่าระบบการตรวจสอบและการแจ้งเตือนอัตโนมัติเพื่อติดตามสถานะของกระแสข้อมูลและรับการแจ้งเตือนในกรณีที่ล้มเหลวหรือปัญหาด้านประสิทธิภาพการทํางาน
  • การรวมข้อมูล: รวมข้อมูลจากหลายแหล่ง เช่น ฐานข้อมูล data lakes และบริการระบบคลาวด์ ลงในกระแสข้อมูลแบบรวมสําหรับการประมวลผลและวิเคราะห์
  • การจัดการข้อผิดพลาด: ใช้การจัดการข้อผิดพลาดแบบกําหนดเองและกลไกการลองใหม่เพื่อให้แน่ใจว่ากระแสข้อมูลทํางานได้อย่างราบรื่นและกู้คืนจากความล้มเหลว

ทําความเข้าใจเกี่ยวกับ API

ในการใช้ API สําหรับกระแสข้อมูลใน Fabric Data Factory อย่างมีประสิทธิภาพ จําเป็นต้องทําความเข้าใจแนวคิดและส่วนประกอบที่สําคัญ:

  • จุดสิ้นสุด: จุดสิ้นสุด API ให้การเข้าถึงการดําเนินการกระแสข้อมูลต่างๆ เช่น การสร้าง การอัปเดต และการลบกระแสข้อมูล
  • การรับรองความถูกต้อง: รักษาความปลอดภัยการเข้าถึง API โดยใช้กลไกการรับรองความถูกต้อง เช่น OAuth หรือคีย์ API
  • คําขอและการตอบสนอง: ทําความเข้าใจโครงสร้างของคําขอ API และการตอบสนอง รวมถึงพารามิเตอร์ที่จําเป็นและผลลัพธ์ที่คาดหวัง
  • ขีดจํากัดอัตรา: ระวังขีดจํากัดอัตราที่กําหนดไว้ในการใช้งาน API เพื่อหลีกเลี่ยงการใช้เกินจํานวนคําขอที่อนุญาต

การสนับสนุน CRUD

CRUD ย่อมาจาก Create, Read, Update และ Delete ซึ่งเป็นการดําเนินการพื้นฐานสี่แบบที่สามารถทําได้บนข้อมูล ใน Fabric Data Factory การดําเนินการ CRUD ได้รับการสนับสนุนผ่าน Fabric API สําหรับ Data Factory API เหล่านี้ช่วยให้ผู้ใช้สามารถจัดการกระแสข้อมูลได้โดยทางโปรแกรม นี่คือประเด็นสําคัญบางอย่างเกี่ยวกับการสนับสนุน CRUD:

  • สร้าง: สร้างกระแสข้อมูลใหม่โดยใช้ API ซึ่งเกี่ยวข้องกับการกําหนดโครงสร้างกระแสข้อมูล การระบุแหล่งข้อมูล การแปลง และปลายทาง
  • อ่าน: เรียกใช้ข้อมูลเกี่ยวกับกระแสข้อมูลที่มีอยู่ ซึ่งรวมถึงรายละเอียดเกี่ยวกับการกําหนดค่า สถานะ และประวัติการดําเนินการ
  • อัปเดต: อัปเดตกระแสข้อมูลที่มีอยู่ ซึ่งอาจเกี่ยวข้องกับการแก้ไขโครงสร้างกระแสข้อมูล การเปลี่ยนแหล่งข้อมูล หรือการอัปเดตตรรกะการแปลง
  • ลบ: ลบกระแสข้อมูลที่ไม่ต้องการอีกต่อไป ซึ่งช่วยในการจัดการและทําความสะอาดทรัพยากร

เอกสารอ้างอิงออนไลน์หลักสําหรับ Microsoft Fabric REST API สามารถพบได้ในเอกสาร Microsoft Fabric REST API

วงจรชีวิตของกระแสข้อมูล

เมื่อทํางานกับกระแสข้อมูล คุณจะต้องเข้าใจวงจรชีวิตของกระแสข้อมูลเพื่อให้แน่ใจว่ากระบวนการรวมข้อมูลมีประสิทธิภาพและราบรื่น ขั้นตอนสําคัญในวงจรชีวิตของกระแสข้อมูลประกอบด้วย

  • นิยาม: นี่คือขั้นตอนเริ่มต้นที่คุณสร้างหรือแก้ไขข้อกําหนดของกระแสข้อมูล ซึ่งเกี่ยวข้องกับการระบุแหล่งข้อมูล การแปลง และข้อกําหนด
  • ตีพิมพ์: หลังจากแก้ไขข้อกําหนดของกระแสข้อมูลแล้ว คุณจําเป็นต้องเรียกใช้การดําเนินการเผยแพร่ นี่คือขั้นตอนสําคัญเนื่องจากจะบันทึกการเปลี่ยนแปลงที่เกิดขึ้นกับข้อกําหนดของกระแสข้อมูลและทําให้พร้อมใช้งานสําหรับการดําเนินการ
  • ฟื้นฟู: เมื่อกระแสข้อมูลได้รับการเผยแพร่ คุณสามารถเรียกการดําเนินการ รีเฟรช ได้ ซึ่งทริกเกอร์กระแสข้อมูลเพื่อเรียกใช้ ดึงข้อมูลจากแหล่งข้อมูลที่ระบุ ใช้การแปลงที่กําหนดไว้ และโหลดข้อมูลลงในปลายทาง

เริ่มต้นใช้งาน API สาธารณะสําหรับกระแสข้อมูล

ในส่วนนี้ เราจะกล่าวถึงหัวข้อต่อไปนี้ทั้งหมด:

รับโทเค็นการรับรองความถูกต้อง

คุณจะต้องมีโทเค็นแบเรอร์สําหรับการเรียกใช้ REST API ทั้งหมด และคุณจะได้รับโดยใช้หนึ่งในตัวเลือกเหล่านี้:

MSAL.Net

การเริ่มต้นใช้งานด่วน Fabric API - Microsoft Fabric REST API

ใช้ MSAL.Net เพื่อรับโทเค็น Microsoft Entra ID สําหรับบริการ Fabric ด้วยขอบเขตต่อไปนี้: Workspace.ReadWrite.All, Item.ReadWrite.All สําหรับข้อมูลเพิ่มเติมเกี่ยวกับการรับโทเค็นที่มี MSAL.Net ดู Token Acquisition - ไลบรารีการรับรองความถูกต้องของ Microsoft สําหรับ .NET

วาง ID แอปพลิเคชัน (ไคลเอนต์) ที่คุณคัดลอกก่อนหน้านี้และวางสําหรับตัวแปร ClientId

พอร์ทัล Fabric

ลงชื่อเข้าใช้ Fabric Portal สําหรับผู้เช่าที่คุณต้องการทดสอบ และกด 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 ในพื้นที่ทํางานที่ระบุ

เอกสาร Mashup ตัวอย่าง

{
    "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

ข้อจํากัดปัจจุบัน

  • การรับรองความถูกต้องแบบโครงร่างสําคัญของบริการ ยังไม่ได้รับการสนับสนุนในขณะนี้
  • "รับหน่วยข้อมูล" และ "รายละเอียดการเข้าถึงรายการ" ไม่ส่งกลับข้อมูลที่ถูกต้องหากคุณกรองประเภทรายการกระแสข้อมูล
  • เมื่อคุณไม่ได้ระบุประเภท จะส่งคืน Dataflow Gen2 (CI/CD, ตัวอย่าง) - Dataflow Gen2 ใหม่ที่รองรับ CI/CD และ GIT
  • เรียกใช้ API ได้ แต่การเรียกใช้จริงไม่เคยสําเร็จ

เนื้อหาที่เกี่ยวข้อง

เอกสาร

บทช่วยสอน

  • Last updated on