擅长:python、mysql、java
<p>我知道这是一个老问题,但我只是试着使用相同的运算符,收到了相同的消息,因为cloudcomposer仍然不支持<code>GoogleCloudStorageToGoogleCloudStorageOperator</code>。在</p>
<p>我用一个简单的BashOperator解决了我所需要的</p>
<pre><code> from airflow.operators.bash_operator import BashOperator
with models.DAG(
dag_name,
schedule_interval=timedelta(days=1),
default_args=default_dag_args) as dag:
copy_files = BashOperator(
task_id='copy_files',
bash_command='gsutil -m cp <Source Bucket> <Destination Bucket>'
)
</code></pre>
<p>非常简单,可以创建文件夹,如果你需要和重命名你的文件。在</p>