Передача параметров воздушного потока в скрипт Shell

Question

Я пытаюсь вызвать сценарий оболочки в моей группе DAG с потоком воздуха и передаю несколько аргументов, как указано ниже,

def load_data_parameters():
   today_date = '{{ ds }}'
   environment = config.get('common', 'env') 
   return today_date,environment

today_date,environment = load_data_parameters()

EdgeToRaw_Command ="./scripts/test.sh"

Test = BashOperator(
        task_id= 'Test-Task',
        bash_command=EdgeToRaw_Command,
        params = {'env': environment},
        dag=dag)

В сценарии оболочки просто пытаюсь выполнить печать,

envi=$1
echo $envi

Возможнокто-нибудь, помогите, что не так в этом, или скажите, как передать параметр в BashOperator, который вызывает скрипт для выполнения какой-либо задачи.

Answer 1

В вашем сценарии оболочки вы должны иметь следующее

envi={{params.env}}
echo $envi

По сути, все, что вы передаете аргументу params в BashOperator, должно вызываться {{params.PARAMETER_NAME}}