Шаблон потока данных - это не код python или java, а скомпилированная версия кода, который вы написали в python или java. Поэтому, когда вы создаете шаблон, вы можете передать requirements.txt
в аргументах, как обычно, как показано ниже
python dataflow-using-cf.py \
--runner DataflowRunner \
--project <PROJECT_ID> \
--staging_location gs://<BUCKET_NAME>/staging \
--temp_location gs://<BUCKET_NAME>/temp \
--template_location ./template1 \
--requirements_file ./requirements.txt \
Приведенная выше команда создаст файл с именем template1
, который, если вы read, содержит структуру JSON, этот файл является скомпилированной версией кода потока данных, который вы написали, и в процессе компиляции он прочитает ваш requirements.txt
из вашего локального каталога и скомпилирует его шаги. Затем вы можете добавить свой шаблон в корзину и указать путь к облачной функции, вам не нужно беспокоиться о файле requirements.txt
после создания шаблона.