[BUG] Azure Functions (Python V2 model) doesn't seem to support Session-based Service Bus Queue triggering

[TDehaene]

Investigative information

Please provide the following:

• Timestamp: 2023-04-05 10:04
• Function App name: hoiaipocnonprdeuwfacdc
• Function name(s) (as appropriate): cdc
• Core Tools version: 4.0.5095

Repro steps

Provide the steps required to reproduce the problem:

• Package Name: azure-functions
• Package Version: 1.13.3
• Operating System: WSL Ubuntu (in VSCode) and Windows 11
• Python Version: 3.10.4

I'm trying to create a Azure Service Bus Queue - triggered function using the Python v2 programming model, but I'm running into a bug.

I'm mainly following the steps outlined in this article: https://learn.microsoft.com/en-us/azure/azure-functions/functions-bindings-service-bus-trigger?tabs=python-v2%2Cin-process%2Cextensionv5&pivots=programming-language-python

The only difference being that the Queue I have created is Session-aware.

I'm trying to figure out how to specify the Session-id, but can't seem to find it back in the documentation, nor anywhere online.

Expected behavior

Screenshots Full screenshot from the logstream:

Expected behavior

Provide a description of the expected behavior.

That I'm either able provide the Session-id as a decorator parameter, or that the functioning of the Queue-trigger for session-aware queues is agnostic, and can take in messages normally.

Actual behavior

Provide a description of the actual behavior observed.

The error message is as follows:

[Error]   ReceiveBatchAsync Exception: System.InvalidOperationException: It is not possible for an entity that requires sessions to create a non-sessionful message receiver.

It works fine for a non-Session-aware Queue trigger, but it starts throwing the error if I make it Session-aware. I also can't seem to find any parameter for the decorator that would allow me to specify the Session-id.

Contents of the requirements.txt file:

Provide the requirements.txt file to help us find out module related issues.

azure-functions
azure-identity
azure-servicebus

[bhagyshricompany]

@gavin-aguiar pls comment and validate

[LizaKing0]

I'm having the same errors with Python 3.10, v2 programming model. The examples here don't help either. Is this a bug? Or has anyone found a more complete example that works?

[sudharsan2020]

@TDehaene I've been experiementing Service Bus sessions recently. Not sure if the below code could help you.

import json
from typing import List

from azure.servicebus import ServiceBusMessage
from azure.servicebus.aio import ServiceBusClient

client = ServiceBusClient.from_connection_string("SB-CONN-STRING")

async def sample_session_send_receive_with_pool_async(
            pay_load,
            session_id,
        ):
    async with client.get_topic_sender(topic_name='nextstep-service-bus') as sender:
        await sender.send_messages(
            ServiceBusMessage(
                body=json.dumps(pay_load, default=str),
                session_id=session_id,
                subject='AI_SESSIONS_DEMO'
            )
        )

Please check this for more examples: https://github.com/Azure/azure-sdk-for-python/tree/main/sdk/servicebus/azure-servicebus/samples/sync_samples