AirflowにはAzureのパッケージが存在しています。 pip install 'apache-airflow[azure]' その辺りを使って、Azure Blob Storageへオブジェクトがアップロードしたことを検知して、ワークフローを流したいと思いました。 モジュールとしては以下のモジュールが該当するSensorモジュールになります。 https://github.com/apache/airflow/blob/1.10.4/airflow/contrib/sensors/wasb_sensor.py WasbBlobSensor と WasbPrefixSensor がそれにあたり、ドキュメント上も以下などに記載があるのですが、結構わかりにくかったのでメモしておきます。 airflow.apache.org 最新番のAzureのSDKでは動かない いきなりのつっかかりポイン
![Apache AirflowでAzure BLOB Storageのオブジェクトを監視してワークフローをトリガする - YOMON8.NET](https://cdn-ak-scissors.b.st-hatena.com/image/square/72f4b34d36e281855c89e22a66e47db3443a8afb/height=288;version=1;width=512/https%3A%2F%2Fcdn-ak.f.st-hatena.com%2Fimages%2Ffotolife%2Fy%2Fyomon8%2F20191202%2F20191202000544.png)