Azure Functions Queue empty

Question

I am new to Azure. Forgive me if the question is basic. I have the following http trigger intended to stream messages to the Queue Storage.

import logging
import azure.functions as func
def main(req: func.HttpRequest, msg: func.Out[func.QueueMessage]) -> func.HttpResponse:
    logging.info('Python HTTP trigger function processed a request.')
    input_msg = req.params.get('message')
    logging.info(input_msg)
    msg.set(input_msg)

    return func.HttpResponse(status_code=200, body='GotIt')

Tested it Locally and;

Deployed it and it runs ok as well

However, when I check the queue it is empty;

Questions;

Why is the queue empty and what can I do to ensure it registers messages?
Is it not locking because my code is not writing messages?

Your help will be highly appreciated.

Yes, it did not... and cant just figure out what the issue is. — wwnde
– wwnde, Commented Nov 13, 2020 at 7:13
@ Bowman Zhu from my local run it prints GotIt. Nothing goes into the queue — wwnde
– wwnde, Commented Nov 13, 2020 at 7:15
I have post an answer, you can have a try to see whether the problem still happens on your side. — suziki
– suziki, Commented Nov 13, 2020 at 7:18

suziki · Accepted Answer · 2020-11-13 07:24:27Z

1

Update:

function.json

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "authLevel": "anonymous",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": [
        "get",
        "post"
      ]
    },
    {
      "type": "http",
      "direction": "out",
      "name": "$return"
    },
    {
      "type": "queue",
      "direction": "out",
      "name": "msg",
      "queueName": "outqueue",
      "connection": "AzureStorageQueuesConnectionString"
    }
  ]
}

local.settings.json

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "",
    "FUNCTIONS_WORKER_RUNTIME": "python",
    "AzureStorageQueuesConnectionString":"DefaultEndpointsProtocol=https;AccountName=0730bowmanwindow;AccountKey=xxxxxx;EndpointSuffix=core.windows.net"
  }
}

host.json

{
  "version": "2.0",
  "logging": {
    "applicationInsights": {
      "samplingSettings": {
        "isEnabled": true,
        "excludedTypes": "Request"
      }
    }
  },
  "extensionBundle": {
    "id": "Microsoft.Azure.Functions.ExtensionBundle",
    "version": "[1.*, 1.2.0)"
  }
}

Original Answer:

I have do a simple test. Below code works fine on my side, you can have a try:

import logging

import azure.functions as func


def main(req: func.HttpRequest,msg: func.Out[str]) -> func.HttpResponse:
    logging.info('Python HTTP trigger function processed a request.')
    input_msg = req.params.get('message')
    logging.info(input_msg)
    msg.set(input_msg)
    return func.HttpResponse(
            "This is a test.",
            status_code=200
    )

This is the doc:

https://learn.microsoft.com/en-us/azure/azure-functions/functions-bindings-storage-queue-output?tabs=python#example

Send:

Queue Storage:

edited Nov 13, 2020 at 7:24

answered Nov 13, 2020 at 7:15

suziki

14.2k1 gold badge20 silver badges31 bronze badges

Sign up to request clarification or add additional context in comments.

18 Comments

wwnde Over a year ago

I will try and revert

wwnde Over a year ago

still nothing gets written

suziki Over a year ago

@wwnde I test the same code of you. I works with no problem. So it should have no problem with your code. Any limit of your storage account? You can also have a check of the configuration settings I updated.

wwnde Over a year ago

are there queue settings that maybe I need to check?

suziki Over a year ago

@wwnde If you use connection string you should have totally access to queue. Can you show the structure of your AzureStorageQueuesConnectionString?(No need to show the account key and account)

|

Collectives™ on Stack Overflow

Azure Functions Queue empty

1 Answer 1

18 Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

18 Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related