Megosztás:

Webhook-tevékenység az Azure Data Factoryben

A következőkre vonatkozik: Azure Data Factory Azure Synapse Analytics

Tipp.

Próbálja ki a Data Factoryt a Microsoft Fabricben, amely egy teljes körű elemzési megoldás a nagyvállalatok számára. A Microsoft Fabric az adattovábbítástól az adatelemzésig, a valós idejű elemzésig, az üzleti intelligenciáig és a jelentéskészítésig mindent lefed. Ismerje meg, hogyan indíthat új próbaverziót ingyenesen!

A webhook-tevékenységek egyéni kóddal szabályozhatják a folyamatok végrehajtását. A webhook-tevékenységgel a kód meghívhat egy végpontot, és visszahívási URL-címet adhat át neki. A folyamat megvárja a visszahívást, mielőtt továbblép a következő tevékenységre.

Fontos

A WebHook-tevékenység mostantól lehetővé teszi a hibastátusz és az egyéni üzenetek visszajelzését a tevékenységhez és a pipeline-hoz. Állítsa a reportStatusOnCallBack értéket true értékre, és adja hozzá a StatusCode és Error értékeket a visszahívás hasznos adataihoz. További információ: További megjegyzések szakasz.

Webhook-tevékenység létrehozása felhasználói felülettel

Ha webhook-tevékenységet szeretne használni egy folyamatban, hajtsa végre a következő lépéseket:

  1. Keresse meg a Webhookot a folyamattevékenységek panelen, és húzzon egy Webhook-tevékenységet a folyamatvászonra.

  2. Válassza ki az új webhook-tevékenységet a vászonon, ha még nincs kijelölve, és a Beállítások fület a részletek szerkesztéséhez.

    Egy webhook-tevékenység felhasználói felületét jeleníti meg.

  3. Adjon meg egy URL-címet a webhook számára, amely lehet egy literális URL-sztring, vagy a dinamikus kifejezések, függvények, rendszerváltozók vagy más tevékenységek kimeneteinek bármilyen kombinációja. Adja meg a kéréssel elküldendő egyéb adatokat.

  4. Használja a tevékenység kimenetét bármely más tevékenység bemeneteként, és hivatkozzon arra a kimenetre, ahol a dinamikus tartalom támogatott a céltevékenységben.

Szintaxis


{
    "name": "MyWebHookActivity",
    "type": "WebHook",
    "typeProperties": {
        "method": "POST",
        "url": "<URLEndpoint>",
        "headers": {
            "Content-Type": "application/json"
        },
        "body": {
            "key": "value"
        },
        "timeout": "00:10:00",
        "reportStatusOnCallBack": false,
        "authentication": {
            "type": "ClientCertificate",
            "pfx": "****",
            "password": "****"
        }
    }
}

Típustulajdonságok

Tulajdonság Leírás Megengedett értékek Szükséges
név A webhook-tevékenység neve. Sztring Igen
típus A "WebHook" értéket kell beállítani. Sztring Igen
módszer A célvégpont REST API-metódusa. Szöveg. A támogatott típus a "POST". Igen
URL-cím A célvégpont és az elérési út. Sztring vagy kifejezés egy karakterlánc resultType értékével. Igen
Fejlécek A kérelemnek küldött fejlécek. Íme egy példa, amely beállítja a nyelvet, és beír egy kérést: "headers" : { "Accept-Language": "en-us", "Content-Type": "application/json" }. Sztring vagy kifejezés a sztring resultType értékével. Igen. Szükség van egy Content-Type fejlécre "headers":{ "Content-Type":"application/json"} .
test A végpontnak küldött hasznos adatokat jelöli. Érvényes JSON vagy JSON resultType értékkel rendelkező kifejezés. Lásd a kérelem hasznos adatsémáját a kérelem hasznos adatainak sémájáért. Igen
hitelesítés A végpont meghívására használt hitelesítési módszer. A támogatott típusok az "Alapszintű" és a "ClientCertificate". További információért lásd: Hitelesítés. Ha nincs szükség hitelesítésre, zárja ki ezt a tulajdonságot. Egy karakterlánc vagy kifejezés, amelynek resultType értéke egy karakterlánc. Nem
időkorlát Mennyi ideig vár a tevékenység a callBackUri által megadott visszahívás meghívására. Az alapértelmezett érték 10 perc ("00:10:00"). Az értékek a d.óó:pp:mp formátumú TimeSpan-t követik. Sztring Nem
A visszahívás állapota Lehetővé teszi, hogy a felhasználó jelentse egy webhook-tevékenység sikertelen állapotát. Boolean Nem

Hitelesítés

A webhook-tevékenységek a következő hitelesítési típusokat támogatják.

Egyik sem

Ha nincs szükség hitelesítésre, ne tartalmazza a hitelesítési tulajdonságot.

Alap

Adja meg az alapszintű hitelesítéshez használni kívánt felhasználónevet és jelszót.

"authentication":{
   "type":"Basic",
   "username":"****",
   "password":"****"
}

Ügyféltanúsítvány

Adja meg egy PFX-fájl Base64 kódolású tartalmát és egy jelszót.

"authentication":{
   "type":"ClientCertificate",
   "pfx":"****",
   "password":"****"
}

Felügyelt identitás

A data factory vagy a Synapse-munkaterület felügyelt identitásával adja meg azt az erőforrás-URI-t, amelyhez a hozzáférési jogkivonatot kérik. Az Azure Resource Management API meghívásához használja a következőt https://management.azure.com/: . A felügyelt identitások működésével kapcsolatos további információkért tekintse meg az Azure-erőforrások felügyelt identitásainak áttekintését.

"authentication": {
    "type": "MSI",
    "resource": "https://management.azure.com/"
}

Feljegyzés

Ha a szolgáltatás Git-adattárral van konfigurálva, a hitelesítő adatokat az Azure Key Vaultban kell tárolnia az alapszintű vagy ügyféltanúsítvány-hitelesítés használatához. A szolgáltatás nem tárolja a jelszavakat a Gitben.

További megjegyzések

A szolgáltatás a callBackUri további tulajdonságot a törzsben továbbítja az URL-végpontnak. A szolgáltatás elvárja, hogy az URI a megadott időtúllépési érték előtt legyen meghívva. Ha az URI nem hívható meg, a tevékenység "TimedOut" állapottal meghiúsul.

A webhook-tevékenység meghiúsul, ha az egyéni végpont hívása meghiúsul. Bármilyen hibaüzenet hozzáadható a visszahívási törzshez, és felhasználható egy későbbi tevékenységben.

Minden REST API-hívás esetén az ügyfél időtúllépést hajt végre, ha a végpont egy percen belül nem válaszol. Ez a viselkedés általános HTTP-ajánlott eljárás. A probléma megoldásához implementáljon egy 202-s mintát. Az aktuális esetben a végpont a 202-et (Elfogadva) adja vissza, és az ügyfél lekérdezi.

A kérelem egyperces időtúllépésének semmi köze a tevékenység időtúllépéséhez. Az utóbbi a callbackUri által megadott visszahívásra való várakozásra szolgál.

A callback URI-n keresztül visszaadott adatoknak érvényes JSON-nak kell lenniük. Állítsa be a Content-Type fejlécet a következőre application/json: .

Ha a visszahívási tulajdonság jelentésállapotát használja, a visszahíváskor a következő kódot kell hozzáadnia a törzshöz:

{
    "Output": {
        // output object is used in activity output
        "testProp": "testPropValue"
    },
    "Error": {
        // Optional, set it when you want to fail the activity
        "ErrorCode": "testErrorCode",
        "Message": "error message to show in activity error"
    },
    "StatusCode": "403" // when status code is >=400, activity is marked as failed
}

Kapcsolódó tartalom

Tekintse meg a következő támogatott vezérlési folyamatokat:

  • Last updated on