Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
L'esempio seguente illustra i passaggi per creare un plug-in personalizzato che generi variabili di ambiente in fase di esecuzione in un ambiente Amazon Managed Workflows for Apache Airflow.
Argomenti
Versione
Prerequisiti
Per utilizzare il codice di esempio in questa pagina, avrai bisogno di quanto segue:
-
Un ambiente Amazon MWAA.
Autorizzazioni
-
Non sono necessarie autorizzazioni aggiuntive per utilizzare l'esempio di codice in questa pagina.
Requisiti
-
Per utilizzare questo esempio di codice con Apache Airflow v1, non sono richieste dipendenze aggiuntive. Il codice utilizza l'installazione di base di Apache Airflow v1
nell'ambiente in uso.
Plugin personalizzato
Apache Airflow eseguirà il contenuto dei file Python nella cartella plugins all'avvio. Viene utilizzato per impostare e modificare le variabili di ambiente. I passaggi seguenti descrivono il codice di esempio per il plug-in personalizzato.
-
Nel prompt dei comandi, accedete alla directory in cui sono archiviati i plugin. Per esempio:
cd plugins -
Copia il contenuto del seguente esempio di codice e salvalo localmente come
env_var_plugin.pynella cartella precedente.from airflow.plugins_manager import AirflowPlugin import os os.environ["PATH"] = os.getenv("PATH") + ":/usr/local/airflow/.local/lib/python3.7/site-packages" os.environ["JAVA_HOME"]="/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.272.b10-1.amzn2.0.1.x86_64" class EnvVarPlugin(AirflowPlugin): name = 'env_var_plugin'
Plugins.zip
I passaggi seguenti mostrano come creareplugins.zip. Il contenuto di questo esempio può essere combinato con altri plugin e binari in un unico plugins.zip file.
-
Nel prompt dei comandi, accedete alla
hive_plugindirectory del passaggio precedente. Per esempio:cd plugins -
Comprimi il contenuto all'interno della
pluginscartella.zip -r ../plugins.zip ./
Opzioni di configurazione del flusso d'aria
Se utilizzi Apache Airflow v2, aggiungilo core.lazy_load_plugins : False come opzione di configurazione Apache Airflow. Per saperne di più, consulta Usare le opzioni di configurazione per caricare i plugin in 2.
Fasi successive
-
Scopri come caricare il
requirements.txtfile in questo esempio nel tuo bucket Amazon S3 in. Installazione delle dipendenze in Python -
Scopri come caricare il codice DAG in questo esempio nella
dagscartella del tuo bucket Amazon S3 in. Aggiungere o aggiornare DAGs -
Scopri di più su come caricare il
plugins.zipfile in questo esempio nel tuo bucket Amazon S3 in. Installazione di plugin personalizzati
