Я пытаюсь использовать Cloud Composer для запуска моего рабочего процесса. Я хотел использовать...
У меня есть среда Airflow, работающая на Cloud Composer (3 n1-standard-1 узлы; версия образа:...
Я планирую использовать Google Cloud Composer для планирования рабочего процесса, который загружает...
Я пытался импортировать JSON-файл переменных среды во вновь созданный экземпляр Cloud Composer,...
Попытка выполнить запрос с помощью pythonoperator (используя BigQueryHook) def...
Я пытаюсь запустить PythonVirtualenvOperator в dag в gcloud composer среде, но получаю ошибку при...
Попытка сделать некоторые засыпки, и все прогоны даг запускаются нормально, но по какой-то причине...
У меня DAG, где max_active_runs установлено на 2, но теперь я хочу запускать засыпки для 20-ти...
Я использую Dataprep для создания шаблона потока данных, который в основном выполняет вставку...
В Airflow - я пытаюсь зациклить оператора.(BigQueryOperator).Группа обеспечения доступности баз...
Я хочу знать статус всех выполненных задач.Мы можем сделать это вручную, но я хочу узнать это через...
После запуска в течение нескольких дней веб-интерфейс Google Cloud Composer бесконечно возвращает...
Как запустить Dag воздушного потока для указанного количества раз? Я пытался использовать...
Я создал среду композитора с помощью интерфейса консоли, а затем установил три переменные с помощью...
У меня работает DAG на локальном Airflow.Я запустил Cloud Composer и хотел перенести туда свои DAG
Я не могу обновить уже созданную среду google-cloud-composer.Это происходит, если я работаю с уже...
Я хочу зарегистрировать сообщение с пользовательским показателем в DAG Google Cloud Composer
При выполнении следующего скрипта Python с использованием cloud-composer, я получаю *** Task...
После некоторых исследований и испытаний мы решили начать использовать Google Cloud Composer....
Я принимаю 2 разных набора данных в GCS. Допустим, я пишу событие e1 и событие e2 соответственно в...
Некоторый контекст: Я использую composer-1.3.0-airflow-1.10.0 Установленный пакет PyPi docker===2.7
Мы используем соединение JDBC в потоке воздуха для получения данных с общедоступного сервера MySQL....
Я пытался установить Dask на Google Composer (Airflow). Я использовал pypi (GCP UI), чтобы добавить...
Так что у меня уже есть пустое хранилище для этого, и я не хочу, чтобы composer создавал свое...
Я хочу получить доступ к сервисам AWS из моей системы воздушных потоков, управляемой облачным...