Привет, я пытаюсь загрузить файл из GCS в Gdrive, используя
airflow.contrib.operators.gcs_to_gdrive_operator import GcsToGDriveOperator
Так выглядит даг
copy_to_gdrive = GcsToGDriveOperator(
task_id="copy_to_gdrive",
source_bucket="my_source_bucket_on_gcs",
source_object="airflow-dag-test/report.csv",
destination_object="/airflow-test/report.csv",
gcp_conn_id="bigquery_default",
dag=dag
)
Этот код выполняется без каких-либо ошибок, и в журналах я вижу, что файл успешно загружен на локальный диск и также успешно загружен на gdrive.
Этот код выполняется учетной записью службы, проблема, с которой я сталкиваюсь, заключается в том, что я не могу найти файл или каталог, который этот даг создает для загрузки
Я пробовал несколько перестановок/комбинаций пути для target_object, но, похоже, ничего не работает, а документы Google также бесполезны.
В журналах API я вижу, что API drive.create вызывается, но где он создает файл, неизвестно. Кто-нибудь испытал это? любая помощь или подсказка были бы большим подспорьем. Спасибо!
