I’d like to trigger some flows whenever a new file is added to a Google Drive folder. My current plan is to run a small python server that receives webhook calls from the Drive API, then uses the Prefect API to trigger the flows. Questions:
1. Is the right Prefect API to use the GraphQL API mutations API
createFlowRun
?
2. Is there anything like this around already? Would love to not reinvent the wheel and deploy a new service.
n
nicholas
06/02/2021, 7:44 PM
Hi @Jason Prado - the correct API call to use is
create_flow_run
(the camelCased route is deprecated).
Another option besides a standalone webserver would be to use something like AWS Lambda or Google Cloud function to create the call. Those typically incur a much lower overhead. This blog post might be interesting for your use case.
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.