python - 运行python脚本的Nifi问题

我的用例是：我有 2013-2019 年的出租车数据，我想从 Bigquery 获取 2018 年的数据到 Google 云存储，然后到 Amazon S3 存储桶。

我已经编写了一个 python 脚本，它成功地将数据传输到 Google Cloud Storage 存储桶。

另外，我制作了一个 nifi 流，它成功地将 GCP Bucket 数据传输到 Amazon S3。

问题是我无法在 nifi 中创建流，当我的 python 脚本成功执行时，会触发流（我已经创建）。基本上我无法连接（运行我的 python 脚本）和（nifi 流）。我想自动化它。

标签： pythongoogle-cloud-platformgoogle-bigquerybigdataapache-nifi