call Orchestrator Function

Question

call Orchestrator Function

Gerald Rupp 130

Hallo everybody,

I have a Blob-Trigger Azure Function in python. Inside that Function I am calling an orchestrator-Function. I have problems to initialize the client.

Hope you can help me :)

This is my code so far:

def main(myblob: func.InputStream):
    # Get the blob URI
    blob_uri = myblob.uri
    logging.warning(f"Triggered by = '{blob_uri}'")
    
    if blob_uri.endswith('.json')==True:
        # Create a DurableOrchestrationClient
        client = ??

        # Start the orchestrator function and pass the blob URI as input
        instance_id = client.start_new('OrchestratorRailster', None, blobUri=blob_uri)

        logging.warning(f"Started orchestration with ID = '{instance_id}'")
    else:
        logging.warning(f"no json-file was modified. No Action for: '{blob_uri}'")

Accepted answer

0 additional answers

Your answer

Answer 1

navba-MSFT 27,550 Microsoft Employee Moderator

@Gerald Rupp Welcome to Microsoft Q&A Forum, Thank you for posting your query here!

I understand that you are having trouble initializing the client to call an orchestrator function.

Could you please test if the below sample helps ?

Within _init_.py have the below code:

import logging
import azure.functions as func
import azure.durable_functions as df

async def main(myblob: func.InputStream, starter: str):
    logging.info("Python blob trigger function processed blob)  

    client = df.DurableOrchestrationClient(starter)
    instance_id = await client.start_new('YourNewDurableFunction')

I hope you have already added the function.json as below:

  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "myblob",
      "type": "blobTrigger",
      "direction": "in",
      "path": "ContainerName/{name}",
      "connection": "AZURE_STORAGE_CONNECTION_STRING"
    },
    {
      "name": "starter",
      "type": "durableClient",
      "direction": "in"
    }
  ]
}

I am also sharing a few useful articles if that helps: I am sharing a few useful articles related to similar ask:

https://learn.microsoft.com/en-us/answers/questions/59760/use-durable-function-with-blobstorage-trigger-and

https://stackoverflow.com/questions/53784657/durable-function-blob-trigger https://learn.microsoft.com/en-us/azure/azure-functions/durable/durable-functions-instance-management?tabs=python https://stackoverflow.com/questions/72344826/using-python-blob-trigger-as-durable-client-in-azure

Hope this helps.

**
Please do not forget to "Accept the answer” and “up-vote” wherever the information provided helps you, this can be beneficial to other community members.

Gerald Rupp 130 Reputation points

2023-08-10T11:23:44.8+00:00
Thanks a lot, that clarifies a lot. But one think I do not understand, yet:

Inside my Orchestrator-Function I needs the Blob URI from the Blob which triggered my function.

I am getting access to that value by:

def orchestrator_function(context: df.DurableOrchestrationContext): blob_info = context._input # This should contain the blob information from the trigger blob_uri = blob_info["blobUri"]

How do I give this information from trigger-function to orchestrator function? Do I have to take it into account in that line: instance_id = await client.start_new('YourNewDurableFunction') ?

Thanks a lot :)
navba-MSFT 27,550 Reputation points Microsoft Employee Moderator

2023-08-10T12:46:26.8733333+00:00
@Gerald Rupp Thanks for getting back.

To answer your question, Yes, you can pass the blob information from the trigger function to the orchestrator function by including it in the input parameter of the start_new method.

In my above trigger function sample, you can modify the start_new method call to include the blob information as follows:

import logging import azure.functions as func import azure.durable_functions as df async def main(myblob: func.InputStream, starter: str): logging.info("Python blob trigger function processed blob) client = df.DurableOrchestrationClient(starter) instance_id = await client.start_new('YourNewDurableFunction', None, {"blobUri": myblob.uri})

YourNewDurablefunction name should be replaced by your function name.

In your orchestrator function, you can then access the blob information from the input parameter as follows:

import azure.durable_functions as df def orchestrator_function(context: df.DurableOrchestrationContext): blob_info = context._input blob_uri = blob_info["blobUri"] # rest of your code

This way, the blobUri value from the trigger function will be passed to the orchestrator function as input.
Sharing some useful article if that helps:
https://stackoverflow.com/questions/72344826/using-python-blob-trigger-as-durable-client-in-azure
https://learn.microsoft.com/en-us/azure/azure-functions/durable/durable-functions-bindings?tabs=python-v2%2Cin-process%2C2x-durable-functions&pivots=programming-language-python
https://stackoverflow.com/questions/74493154/how-do-i-pass-the-input-of-a-blob-triggered-starter-function-to-activity-functio
https://stackoverflow.com/questions/74770296/returning-a-big-object-from-activity-function-throws-an-error

If you face any issues, with this, please let me know. I would be happy to help.

**
Please do not forget to "Accept the answer” and “up-vote” wherever the information provided helps you, this can be beneficial to other community members.
navba-MSFT 27,550 Reputation points Microsoft Employee Moderator

2023-08-14T07:20:12.7233333+00:00

@Gerald Rupp Just following up to check if the below answer helped. If that answers your query, do click "Accept the answer” for the same, which might be beneficial to other community members reading this thread. And, if you have any further query do let us know. I would be happy to help.
Gerald Rupp 130 Reputation points

2023-08-14T07:25:21.7266667+00:00

Your answered helped nearly to fix my problem.
I got this error:

[2023-08-10T22:08:36.425Z] 77fc8ba6c7434c73a3afe8893816fe01: Function 'OrchestratorName (Orchestrator)' failed with an error. Reason: Message: string indices must be integers,

It seems that the dict is transferred as string and therefore I had to convert it via json.load(blob_info)
navba-MSFT 27,550 Reputation points Microsoft Employee Moderator

2023-08-14T07:28:20.5866667+00:00

@Gerald Rupp Thanks for the update. I am glad that your issue is resolved and you are unblocked. Please feel free to reach-out to the Microsoft Q&A forum for any technical issue in future. We would be happy to help.

Share via

call Orchestrator Function

0 additional answers

Your answer