Folyamat visszatérési értékének beállítása az Azure Data Factoryben és az Azure Synapse Analyticsben

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 hívófolyamat-gyermekfolyamat paradigmában a Változó beállítása tevékenység használatával visszaadhatja a gyermekfolyamat értékeit a hívófolyamat számára. A következő forgatókönyvben egy gyermekfolyamatot futtatunk a Execute Pipeline Activity segítségével. Szeretnénk lekérni az adatokat az alfolyamatból, és azt használjuk a hívási folyamatban.

Vezesse be a csővezetéki visszatérési értéket, amely egy kulcs-érték párokból álló szótár, lehetővé téve a gyermekcsővezetékek és a szülőcsővezeték közötti kommunikációt.

Előfeltétel – Gyermekfolyamat meghívása

Előfeltételként a tervezéshez gyermekfolyamatot hívó folyamat-végrehajtási tevékenységre van szükség, és a tevékenységen engedélyezve van a várakozás a befejezéskor .

Folyamat visszatérési értékének konfigurálása az alfolyamatban

A Változó beállítása tevékenységet kibontottuk, hogy tartalmazza a rendszerváltozók folyamat-visszatérési értékét. Ezeket nem kell folyamatszinten definiálnia (szemben a folyamatban használt többi változóval).

1. Keresse meg a Változó beállítása lehetőséget a folyamattevékenységek panelen, és húzza a Változó beállítása tevékenységet a folyamatvászonra.
2. Ha még nincs kijelölve, jelölje ki a Változó Beállítása tevékenységet a munkaterületen, majd a Változók lapon szerkessze a részleteket.
3. Válassza a Pipeline visszatérési értéket változótípusnak.
4. Új kulcsértékpár hozzáadásához válassza az Új lehetőséget.
5. A hozzáadható kulcs-érték párok számát csak a visszaadott JSON méretkorlátja (4 MB) korlátozza.

Az értéktípusoknak van néhány lehetősége, többek között

Típus neve	Leírás
Sztring	Egy állandó karakterlánc érték. például: "Az ADF fantasztikus"
Kifejezés	Lehetővé teszi, hogy hivatkozzon a korábbi tevékenységek kimenetére. Itt használhat sztringinterpolációt a sorközi kifejezésértékek, például "The value is @{guid()}", beillesztésére.
Tömb	Sztringértékek tömbje várható. Nyomja le az "enter" billentyűt a tömb értékeinek elválasztásához
Logikai	Igaz vagy hamis
Null	Jelzőhely tartójának állapota; az érték állandó null
Int	Egész szám típusú numerikus érték. Például: 42
Lebeg	Lebegőpontos típusú numerikus érték. Például: 2.71828
Objektum	Csak a bonyolult használati esetek figyelmeztetése . Lehetővé teszi, hogy beágyazza az érték kulcsértékpárjainak listáját

Az objektumtípus értéke a következőképpen van definiálva:

[{"key": "myKey1", "value": {"type": "String", "content": "hello world"}}, 
 {"key": "myKey2", "value": {"type": "String", "content": "hi"}}
]

Érték lekérése a hívási folyamatban

A gyermekfolyamat folyamatvisszaadási értéke lesz a folyamat-végrehajtási tevékenység tevékenységkimenete. Az adatokat a @activity('Execute Pipeline1').output.pipelineReturnValue.keyName fájllal kérdezheti le. A használati eset korlátlan. Használhatja például a

• A gyermekfolyamatból származó int érték a várakozási tevékenység várakozási időszakának meghatározásához.
• A sztring érték az URL meghatározásához a webes tevékenység számára.
• Kifejezésértékhasznos adat egy szkripttevékenységhez naplózási célokra.

A csővezeték visszatérési értékeire való hivatkozásnál két észrevehető kiemelés található.

1. Objektumtípussal tovább bővítheti a beágyazott json objektumot, például @activity('Execute Pipeline1').output.pipelineReturnValue.keyName.nextLevelKey
2. Tömbtípussal megadhatja az indexet a listában @activity('Execute Pipeline1').output.pipelineReturnValue.keyName[0]. A szám nullától indexelt, ami azt jelenti, hogy 0-val kezdődik.

Feljegyzés

Győződjön meg arról, hogy a hivatkozott keyName megtalálható a gyermekfolyamatban. Az ADF-kifejezésszerkesztő nem tudja megerősíteni a hivatkozási ellenőrzést. A csővezeték sikertelen lesz, ha a hivatkozott kulcs hiányzik a csomagban.

Speciális szempontok

• Bár egy pipeline-ban több "Set Pipeline Return Value" tevékenység is szerepelhet, fontos biztosítani, hogy csak az egyiket hajtsák végre benne.

  

  A korábban ismertetett hiányzó kulcsprobléma elkerülése érdekében, amikor a hívási folyamatot végzi, javasoljuk, hogy az alfolyamat összes ágához ugyanazt a kulcslistát használja. Érdemes lehet null típusú kulcsokat használni olyan kulcsokhoz, amelyek nem rendelkeznek értékekkel egy adott ágban.

• Az Azure Data Factory kifejezési nyelve nem támogatja közvetlenül a beágyazott JSON-objektumokat. Ehelyett karakterláncokat és kifejezéseket kell megfelelően összefűzni.

  Például a következő JSON-kifejezéshez:

  {
    "datetime": "@{utcnow()}",
    "date": "@{substring(utcnow(),0,10)}",
    "year": "@{substring(utcnow(),0,4)}",
    "month": "@{substring(utcnow(),5,2)}",
    "day": "@{substring(utcnow(),8,2)}"
  }
  

  Egyenértékű Azure Data Factory-kifejezés a következő:

  @{
    concat(
      '{',
      '"datetime": "', utcnow(), '", ',
      '"date": "', substring(utcnow(),0,10), '", ',
      '"year": "', substring(utcnow(),0,4), '", ',
      '"month": "', substring(utcnow(),5,2), '", ',
      '"day": "', substring(utcnow(),8,2), '"',
      '}'
    )
  }
  

Kapcsolódó tartalom

További információ egy másik kapcsolódó vezérlőfolyamat-tevékenységről:

• Változótevékenység beállítása
• Változó tevékenység hozzáfűzése