Вы можете использовать Google Cloud Composer , это сервис, который позволяет пользователям управлять оркестровкой рабочих процессов, которая позволяет планировать и отслеживать конвейеры, построен на Apache Airflow, вы можете писать сложные рабочие процессы с использованием Python.
Использование Composer DAG (Направленный ациклический граф), каждая вершина DAG представляет одну задачу, а ребра - направление следующей задачи.
Таким образом, вы можете запланироватьDAG для загрузки данных из BigQuery, обучения вашей модели ML, а затем загрузки результатов в BigQuery.
Я даю вам руководство по написанию DAG с python , также оператором Pythonимеет пакеты для взаимодействия с BigQuery или Tensoflow.