Parameteriseren van taken

Dit artikel biedt een overzicht van het gebruik van parameters met opdrachten en taken, met focus op de specifieke kenmerken van de configuratie voor opdrachten en taken in de gebruikersinterface. U moet ook de broncode-assets die u als taken configureert bijwerken om te verwijzen naar parameters. Parameterverwijzingen variëren per taal en taaktype. Zie access-parameterwaarden van een taak.

Hieronder volgen basisconcepten voor het begrijpen van parameters voor taken:

• Jobparameter: Een sleutel-waardepaar dat is gedefinieerd op banenniveau en naar taken wordt doorgestuurd. Zie Configureer taakparameters.
• Taakparameter: Een sleutel-waardepaar of JSON-matrix die is gedefinieerd op taakniveau. Zie Configuratie van taakparameters.
• Dynamische waardeverwijzingen: een syntaxis voor verwijzingen naar taakvoorwaarden, metagegevens en parameters bij het configureren van taken. Zie Wat is een verwijzing naar dynamische waarden?
• Taakwaarden: een syntaxis voor het vastleggen en verwijzen naar waarden die tijdens de taakuitvoeringen zijn gegenereerd. Zie Taakwaarden gebruiken om informatie door te geven tussen taken.

Wat kunt u doen met parameters?

Voeg parameters toe aan banen en taken voor complexe toepassingsgevallen, waaronder de volgende:

• Voeg uitbreidbare logica toe aan codeassets.
• Uitvoeringen voorwaardelijk maken.
• Verwijzen naar algemene parameters voor meerdere taken.
• Gebruik gegevens die zijn gegenereerd in de ene taak in een andere taak.
• Verwijs naar metagegevens en statusinformatie in het taakuitvoeringsproces.

Wat is het verschil tussen taak- en taakparameters?

Taakparameters zijn sleutel-waardeparen die zijn gedefinieerd op taakniveau. U kunt de standaardinstellingen voor taakparameters overschrijven wanneer u nu uitvoert met verschillende parameters of een taakuitvoering activeren met behulp van de REST API. Taakparameters worden omlaag gepusht naar taken die gebruikmaken van sleutel-waardeparameters. Andere taken kunnen verwijzen naar taakparameters met behulp van dynamische waardeverwijzingen.

Taakparameters zijn sleutel-waardeparen van JSON-matrices die zijn gedefinieerd op taakniveau. Elk taaktype geeft taakwaarden anders door aan de geconfigureerde codeassets. Notebook-taken maken bijvoorbeeld gebruik van de dbutils.widgets submodule, terwijl Python-scripts waarden doorgeven als argumenten aan het script alsof deze vanaf de opdrachtregel worden aangeroepen. Downstreamtaken kunnen verwijzen naar taakparameters van upstream-taken met behulp van dynamische waardeverwijzingen. Zie access-parameterwaarden van een taak.

Werkstromen bouwen met dynamische waarden

Taakparameters die zijn ingesteld met statische waarden, kunnen alleen worden overschreven door de taakdefinitie bij te werken. Het instellen van een statische waarde voor een taakparameter is het configureren van een standaardwaarde, die u kunt overschrijven wanneer u nu uitvoert met verschillende parameters of een taakuitvoering activeren met behulp van de REST API.

Gebruik dynamische waardeverwijzingen bij het definiëren van taakparameters om patronen zoals de volgende te implementeren:

• Gebruik een taakparameter als output_table voor de ene taak en als input_table voor een andere.
• Leg de uitvoer van een notebookquery vast als een lijst en doorloop deze in een For each taak.
• Het maken van een forkinglogica op basis van het aantal records dat is verwerkt met behulp van een If/else-voorwaardetaak .
• Raadpleeg de parameters van andere taken.

Zie Wat is een verwijzing naar dynamische waarden?