Hi Newbie here Was checking fitment of prefect for a etl pro

Question

Hi Newbie here Was checking fitment of prefect for a etl project Can we trigger prefect flow based on condition Say when a file arrives like a file polling service

Dylan · Answer

Hey < Wing Rider> You may find this article helpful

Dylan · Answer

Shorter answer right now there are two ways to kick off a flow run with Prefect Cloud 1 with an http request 2 on a schedule

Dylan · Answer

There are a bunch of great event driven serverless products on the market that will let you make an HTTP request to Cloud Server based on an event Here s an example on how to use one of them

Wing Rider · Answer

Hi < Dylan> would you able to give me an http post request sample

Dylan · Answer

Dylan · Answer

Feel free to use the python client above point up

Dylan · Answer

Otherwise here s the GraphQL <https docs prefect io orchestration concepts flow runs html graphql>

Wing Rider · Answer

Thanks < Dylan> we are trying to invoke directly from Azure logic apps as a direct post request For that we need to give post body and headers I reckon based on the articles the structure of the post request should be below body `mutation ` `create flow run input ` `flow id lt flow id gt ` `parameters a 2 ` ` ` `id` ` ` ` ` Headers `1 Content Type application json ` `2 Authorization Bearer format lt authtoken gt `

Dylan · Answer

Yup That s correct

Wing Rider · Answer

will let you know how it goes

Wing Rider · Answer

tried to do an post request our api is Body `mutation ` `create flow run input flow id e00006c7 e24c 480b b971 0dc90f80668e ` `id` ` ` ` ` Headers ` ` ` Authorization sanitized ` ` Content Type application json ` ` ` Response Status 400 `< DOCTYPE html>` ` lt html lang= en gt ` ` lt head gt ` ` lt meta charset= utf 8 gt ` ` lt title gt Error lt title gt ` ` lt head gt ` ` lt body gt ` ` lt pre gt Bad Request lt pre gt ` ` lt body gt ` ` lt html gt `

Wing Rider · Answer

The body is working fine from the interactive api

Wing Rider · Answer

i believe the problem is with Azure logic apps

Wing Rider · Answer

I am able to invoke the flow from postman

Wing Rider · Answer

i will try from a python client and see if we can invoke it

Dylan · Answer

Hey Wing how did this go

Dylan · Answer

Dylan · Answer

Here s the client code if it s helpful

Wing Rider · Answer

Thanks alot < Dylan> It went fine The code from the blog itself is is working very fine Instead of lambda we exposed it in Azure functions as we are in Azure platform Logic apps just invokes the functions

Dylan · Answer

Awesome

Dylan · Answer

Glad I could help smile

Wing Rider · Answer

I have got a slack notifier question Do I need to start a different thread

Dylan · Answer

I m happy to help here

Wing Rider · Answer

We need to post custom messages to the slack

Wing Rider · Answer

slack notifier as a state handler is working fine for the states

Wing Rider · Answer

but as we are running mapped commands we need to post the variables in slack to understand which variable is executing now and errored

Wing Rider · Answer

for instance startup parameters needs to be printed

Wing Rider · Answer

```<http logger info|logger info> f response slack notifier f response ```

Wing Rider · Answer

Tried this way Logger is working fine but slack notifier didnt post anything even though it didnt throw any error for the above usage

Wing Rider · Answer

do we need to do a context set similar to logger for slack as well

Wing Rider · Answer

`logger = prefect context get logger `

Dylan · Answer

Yes most likely

Dylan · Answer

I believe there s an issue to customize slack messages

Dylan · Answer

via the notifier

Wing Rider · Answer

is it we need atleast the flowid to be displayed to understand which flow got completed

Wing Rider · Answer

if you can giveme a sample it would be helpful