A feladat feladatfeladatokba való futtatásával kapcsolatos környezet átadása
A dinamikus értékhivatkozásokkal olyan feladat- vagy tevékenységfuttatások környezetét adhatja át, mint a feladat vagy a tevékenység neve, a futtatás azonosítója vagy a feladatfuttatás kezdési időpontja. A dinamikus értékhivatkozások sablonalapú változók, amelyeket a feladattevékenység futtatásakor a megfelelő értékek váltanak fel.
Amikor egy feladat fut, a feladatparaméter változót dupla kapcsos zárójelek veszik körül, a program lecseréli és hozzáfűzi egy opcionális sztringértékhez, amely az érték részeként szerepel. Ha például egy 6. feladatazonosítójú futtatás értékével my-job-6
elnevezett MyJobId
paramétert szeretne átadni, adja hozzá a következő tevékenységparamétert:
{
"MyJobID": "my-job-{{job.id}}"
}
A kettős kapcsos zárójelek tartalma nem kiértékelhető kifejezésként, így nem hajthat végre műveleteket vagy függvényeket dupla kapcsos zárójelekben.
A felhasználó által megadott azonosítókat, például a feladatneveket, a tevékenységértékkulcsokat vagy a speciális karaktereket tartalmazó feladatparaméter-neveket úgy kell feloldani, hogy az azonosítókat háttérrel (` `
)körülveszik. Csak alfanumerikus és aláhúzásjeles karakterek használhatók menekülés nélkül.
{
"VariableWithSpecialChars": "{{job.parameters.`param$@`}}"
}
A hivatkozások szintaxishibáit (például egy hiányzó zárójelet) figyelmen kívül hagyja a rendszer, és az értéket konstans sztringként kezeli a rendszer. A függvény például {{my.value}
sztringként "{{my.value}"
van átadva. Egy ismert névtérhez (például {{job.naem}}
) tartozó érvénytelen hivatkozás megadása azonban nem engedélyezett. Hibaüzenet jelenik meg, ha egy ismert névtérhez tartozó érvénytelen hivatkozás van beírva a felhasználói felületen.
A feladat befejezése után a paraméterek feloldott értékeit a Futtatás részletei lapon, a Paraméterek területen tekintheti meg.
Támogatott értékhivatkozások
A következő dinamikus értékhivatkozások támogatottak:
Referencia | Leírás |
---|---|
{{job.id}} |
A feladathoz rendelt egyedi azonosító. |
{{job.name}} |
A feladat neve a feladat futtatásakor. |
{{job.run_id}} |
A feladat futtatásához hozzárendelt egyedi azonosító. |
{{job.repair_count}} |
Az aktuális feladatfuttatás javítási kísérleteinek száma. |
{{job.start_time.[argument]}} |
A feladat futtatásának időpontja (UTC időzóna szerint) alapján megadott érték. A visszatérési érték a argument beállításon alapul. Lásd: Dátum- és időértékek beállításai. |
{{job.parameters.[name]}} |
A feladatszintű paraméter értéke a kulccsal [name] . |
{{job.trigger.type}} |
A feladat futtatásának eseményindító típusa. A lehetséges értékek a következőkperiodic : , run_job_task onetime , , file_arrival continuous és table . |
{{job.trigger.file_arrival.location}} |
Ha ehhez a feladathoz egy fájlérkezés-eseményindító van konfigurálva, a tárolási hely értéke. |
{{job.trigger.time.[argument]}} |
A feladat futtatásának időpontja (UTC időzónában) alapuló érték, amely a cron ütemezéssel rendelkező feladatok legközelebbi percére van kerekítve. A visszatérési érték a argument beállításon alapul. Lásd: Dátum- és időértékek beállításai. |
{{task.name}} |
Az aktuális tevékenység neve. |
{{task.run_id}} |
Az aktuális feladatfuttatás egyedi azonosítója. |
{{task.execution_count}} |
Az aktuális tevékenység futtatásának száma (beleértve az újrapróbálkozást és a javítást is). |
{{task.notebook_path}} |
Az aktuális jegyzetfüzet-feladat jegyzetfüzet-elérési útja. |
{{tasks.[task_name].run_id}} |
A feladat [task_name] futtatásához hozzárendelt egyedi azonosító. |
{{tasks.[task_name].result_state}} |
A tevékenység [task_name] eredményállapota. A lehetséges értékek: success , failed , excluded , canceled , evicted , timedout , upstream_canceled , upstream_evicted és upstream_failed . |
{{tasks.[task_name].execution_count}} |
A tevékenység [task_name] futtatásának száma (beleértve az újrapróbálkozást és a javítást is). |
{{tasks.[task_name].notebook_path}} |
A jegyzetfüzet-feladat [task_name] jegyzetfüzetének elérési útja. |
{{tasks.[task_name].values.[value_name]}} |
A tevékenység értéke a tevékenység [task_name] által beállított kulccsal[value_name] . |
{{workspace.id}} |
A munkaterülethez rendelt egyedi azonosító. |
{{workspace.url}} |
A munkaterület URL-címe. |
Ezeket a hivatkozásokat bármely tevékenységhez beállíthatja, amikor feladatokat hoz létre, szerkeszt egy feladatot, vagy különböző paraméterekkel futtat egy feladatot.
Paramétereket is átadhat egy feladat tevékenységei között tevékenységértékekkel. Lásd: Információk megosztása egy Azure Databricks-feladat tevékenységei között.
Dátum- és időértékek beállításai
Az alábbi argumentumokkal adja meg az időalapú paraméterváltozók visszatérési értékét. Minden visszatérési érték az UTC időzónában megadott időbélyegen alapul.
Argumentum | Leírás |
---|---|
iso_weekday |
Egy 1 és 7 közötti számjegyet ad vissza, amely az időbélyeg hétének napját jelöli. |
is_weekday |
Visszaadja true , ha az időbélyeg egy hétköznap van. |
iso_date |
A dátumot ISO formátumban adja vissza. |
iso_datetime |
Iso formátumban adja vissza a dátumot és az időt. |
year |
Az időbélyeg évrészét adja vissza. |
month |
Az időbélyeg hónaprészét adja vissza. |
day |
Az időbélyeg naprészét adja vissza. |
hour |
Az időbélyeg óra részét adja vissza. |
minute |
Az időbélyeg percrészét adja vissza. |
second |
Az időbélyeg második részét adja vissza. |
timestamp_ms |
Ezredmásodpercben adja vissza az időbélyeget. |
Elavult paraméterváltozók
A következő paraméterváltozók elavultak. Bár továbbra is támogatottak, minden új feladatnak vagy meglévő feladat frissítésének a támogatott értékhivatkozásokat kell használnia. Az ajánlott cserehivatkozás az egyes változók leírásában szerepel.
Változó | Leírás |
---|---|
{{job_id}} |
A feladathoz rendelt egyedi azonosító. A job.id használható helyette. |
{{run_id}} |
A tevékenységfuttatáshoz rendelt egyedi azonosító. A task.run_id használható helyette. |
{{start_date}} |
A tevékenység futtatásának dátuma. A formátum yyyyy-MM-dd utc időzónában. A job.start_time.[argument] használható helyette. |
{{start_time}} |
A fürt létrehozása és előkészítése után a futtatás végrehajtási kezdetének időbélyege. A formátum ezredmásodperc, mivel a UNIX időzónája UTC időzónában van visszaadva System.currentTimeMillis() . A job.start_time.[format] használható helyette. |
{{task_retry_count}} |
Azon újrapróbálkozási kísérletek száma, amelyeket az első kísérlet sikertelensége esetén kíséreltek meg futtatni. Az érték az első kísérletnél 0, az egyes újrapróbálkozásoknál pedig növekmény. A task.execution_count használható helyette. |
{{parent_run_id}} |
Egy több feladatot tartalmazó feladat futtatásához hozzárendelt egyedi azonosító. A job.run_id használható helyette. |
{{task_key}} |
A több tevékenységgel rendelkező feladat részét képező tevékenységhez rendelt egyedi név. A task.name használható helyette. |