Azure Queue Storage message not getting saved in the right queue On Azure Function
const azure = require('azure-storage');
const queueService = azure.createQueueService("UseDevelopmentStorage=true");
module.exports = async function (context, req) {
context.log('JavaScript HTTP trigger function processed a request.');
context.log('Request Headers = ' + JSON.stringify(req.headers));
queueName = 'azurequeue';
if ((req.query.parameter && req.query.func) || (req.body && req.body.parameter && req.body.func)) {
var send = new Object();
var message = 'Hello world!'
queueService.createQueueIfNotExists(queueName,function(err, result, response) {
if (err) {
context.log('here')
context.error(err);
return;
}
if (result.created) {
context.log(`[Queue - Sender] Queue ${queueName} did not exist, created it`);
}
queueService.createMessage(queueName, message , (err, result, res) => {
if (err) {
context.error(`[Queue - Sender] An error occurred: ${JSON.stringify(err)}`);
}
context.log(`[Queue - Sender] Sent: ${JSON.stringify(message)}`);
});
});
send.ans = 'Hello world!';
context.res = {
body: send
};
}
else {
context.res = {
status: 400,
body: "Please pass a name on the query string or in the request body"
};
}
};
i am writing an azure Function with httpTrigger. When triggered is should save to a queue name 'azurequeue' hosted in azure storage emulator.
error i am getting 
Is there something i am doing wrong? how to solve this. why is this happening?
azure azure-storage azure-functions edited Nov 14 at 2:03
Jerry Liu
9,0331628
asked Nov 13 at 11:44
Nafis Islam
689
add a comment |
const azure = require('azure-storage');
const queueService = azure.createQueueService("UseDevelopmentStorage=true");
module.exports = async function (context, req) {
context.log('JavaScript HTTP trigger function processed a request.');
context.log('Request Headers = ' + JSON.stringify(req.headers));
queueName = 'azurequeue';
if ((req.query.parameter && req.query.func) || (req.body && req.body.parameter && req.body.func)) {
var send = new Object();
var message = 'Hello world!'
queueService.createQueueIfNotExists(queueName,function(err, result, response) {
if (err) {
context.log('here')
context.error(err);
return;
}
if (result.created) {
context.log(`[Queue - Sender] Queue ${queueName} did not exist, created it`);
}
queueService.createMessage(queueName, message , (err, result, res) => {
if (err) {
context.error(`[Queue - Sender] An error occurred: ${JSON.stringify(err)}`);
}
context.log(`[Queue - Sender] Sent: ${JSON.stringify(message)}`);
});
});
send.ans = 'Hello world!';
context.res = {
body: send
};
}
else {
context.res = {
status: 400,
body: "Please pass a name on the query string or in the request body"
};
}
};
i am writing an azure Function with httpTrigger. When triggered is should save to a queue name 'azurequeue' hosted in azure storage emulator.
error i am getting
Is there something i am doing wrong? how to solve this. why is this happening?
azure azure-storage azure-functions edited Nov 14 at 2:03
Jerry Liu
9,0331628
asked Nov 13 at 11:44
Nafis Islam
689
1
Instead of sharing screenshot of code, please share the actual code in question itself.
– Gaurav Mantri
Nov 13 at 11:46
add a comment |
const azure = require('azure-storage');
const queueService = azure.createQueueService("UseDevelopmentStorage=true");
module.exports = async function (context, req) {
context.log('JavaScript HTTP trigger function processed a request.');
context.log('Request Headers = ' + JSON.stringify(req.headers));
queueName = 'azurequeue';
if ((req.query.parameter && req.query.func) || (req.body && req.body.parameter && req.body.func)) {
var send = new Object();
var message = 'Hello world!'
queueService.createQueueIfNotExists(queueName,function(err, result, response) {
if (err) {
context.log('here')
context.error(err);
return;
}
if (result.created) {
context.log(`[Queue - Sender] Queue ${queueName} did not exist, created it`);
}
queueService.createMessage(queueName, message , (err, result, res) => {
if (err) {
context.error(`[Queue - Sender] An error occurred: ${JSON.stringify(err)}`);
}
context.log(`[Queue - Sender] Sent: ${JSON.stringify(message)}`);
});
});
send.ans = 'Hello world!';
context.res = {
body: send
};
}
else {
context.res = {
status: 400,
body: "Please pass a name on the query string or in the request body"
};
}
};
i am writing an azure Function with httpTrigger. When triggered is should save to a queue name 'azurequeue' hosted in azure storage emulator.
error i am getting
Is there something i am doing wrong? how to solve this. why is this happening?
azure azure-storage azure-functions edited Nov 14 at 2:03
Jerry Liu
9,0331628
asked Nov 13 at 11:44
Nafis Islam
689
const azure = require('azure-storage');
const queueService = azure.createQueueService("UseDevelopmentStorage=true");
module.exports = async function (context, req) {
context.log('JavaScript HTTP trigger function processed a request.');
context.log('Request Headers = ' + JSON.stringify(req.headers));
queueName = 'azurequeue';
if ((req.query.parameter && req.query.func) || (req.body && req.body.parameter && req.body.func)) {
var send = new Object();
var message = 'Hello world!'
queueService.createQueueIfNotExists(queueName,function(err, result, response) {
if (err) {
context.log('here')
context.error(err);
return;
}
if (result.created) {
context.log(`[Queue - Sender] Queue ${queueName} did not exist, created it`);
}
queueService.createMessage(queueName, message , (err, result, res) => {
if (err) {
context.error(`[Queue - Sender] An error occurred: ${JSON.stringify(err)}`);
}
context.log(`[Queue - Sender] Sent: ${JSON.stringify(message)}`);
});
});
send.ans = 'Hello world!';
context.res = {
body: send
};
}
else {
context.res = {
status: 400,
body: "Please pass a name on the query string or in the request body"
};
}
};
i am writing an azure Function with httpTrigger. When triggered is should save to a queue name 'azurequeue' hosted in azure storage emulator.
error i am getting
Is there something i am doing wrong? how to solve this. why is this happening?
azure azure-storage azure-functions azure azure-storage azure-functions edited Nov 14 at 2:03
Jerry Liu
9,0331628
asked Nov 13 at 11:44
Nafis Islam
689
edited Nov 14 at 2:03
Jerry Liu
9,0331628
asked Nov 13 at 11:44
Nafis Islam
689
edited Nov 14 at 2:03
Jerry Liu
9,0331628
edited Nov 14 at 2:03
Jerry Liu
9,0331628
edited Nov 14 at 2:03
Jerry Liu
9,0331628
9,0331628
asked Nov 13 at 11:44
Nafis Islam
689
asked Nov 13 at 11:44
Nafis Islam
689
asked Nov 13 at 11:44
Nafis Islam
689
689
1
Instead of sharing screenshot of code, please share the actual code in question itself.
– Gaurav Mantri
Nov 13 at 11:46
add a comment |
1
Instead of sharing screenshot of code, please share the actual code in question itself.
– Gaurav Mantri
Nov 13 at 11:46
1
1
Instead of sharing screenshot of code, please share the actual code in question itself.
– Gaurav Mantri
Nov 13 at 11:46
Instead of sharing screenshot of code, please share the actual code in question itself.
– Gaurav Mantri
Nov 13 at 11:46
add a comment |
1 Answer
1
active
oldest
votes
Looks like you mix HttpTrigger and QueueTrigger together.
If you want to use your own logic above to write message to queue, make sure your function.json is like below.
{
"disabled": false,
"bindings": [
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name": "req",
"methods": [
"get",
"post"
]
},
{
"type": "http",
"direction": "out",
"name": "res"
}
]
}
If outputbinding feature provided by Azure function is preferred, let's use code below. No need to worry that azurequeue doesn't exist, output binding internally uses createQueueIfNotExists.
module.exports = async function (context, req) {
context.log('JavaScript HTTP trigger function processed a request.');
context.log('Request Headers = ' + JSON.stringify(req.headers));
if ((req.query.parameter && req.query.func) || (req.body && req.body.parameter && req.body.func)) {
var message = 'Hello world!'
var send = {'ans' : message};
return {
res: {
body: send
},
queueOutput: message
};
}
else {
context.res = {
status: 400,
body: "Please pass a name on the query string or in the request body"
};
return;
}
};
And don't forget to add queue output in function.json.
{
"disabled": false,
"bindings": [
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name": "req",
"methods": [
"get",
"post"
]
},
{
"type": "http",
"direction": "out",
"name": "res"
},
{
"type": "queue",
"direction": "out",
"name":"queueOutput" ,
"queueName": "azurequeue",
"connection":"AzureWebJobsStorage"
}
]
}
To avoid other obstacle in the future, have a look at Azure Function guidance of javascript.
answered Nov 14 at 1:48
Jerry Liu
9,0331628
add a comment |
Your Answer
StackExchange.ifUsing("editor", function () {
StackExchange.using("externalEditor", function () {
StackExchange.using("snippets", function () {
StackExchange.snippets.init();
});
});
}, "code-snippets");
StackExchange.ready(function() {
var channelOptions = {
tags: "".split(" "),
id: "1"
};
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function() {
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using("snippets", function() {
createEditor();
});
}
else {
createEditor();
}
});
function createEditor() {
StackExchange.prepareEditor({
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader: {
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
},
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
});
}
});
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53280342%2fazure-queue-storage-message-not-getting-saved-in-the-right-queue-on-azure-functi%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
1 Answer
1
active
oldest
votes
1 Answer
1
active
oldest
votes
active
oldest
votes
active
oldest
votes
Looks like you mix HttpTrigger and QueueTrigger together.
If you want to use your own logic above to write message to queue, make sure your function.json is like below.
{
"disabled": false,
"bindings": [
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name": "req",
"methods": [
"get",
"post"
]
},
{
"type": "http",
"direction": "out",
"name": "res"
}
]
}
If outputbinding feature provided by Azure function is preferred, let's use code below. No need to worry that azurequeue doesn't exist, output binding internally uses createQueueIfNotExists.
module.exports = async function (context, req) {
context.log('JavaScript HTTP trigger function processed a request.');
context.log('Request Headers = ' + JSON.stringify(req.headers));
if ((req.query.parameter && req.query.func) || (req.body && req.body.parameter && req.body.func)) {
var message = 'Hello world!'
var send = {'ans' : message};
return {
res: {
body: send
},
queueOutput: message
};
}
else {
context.res = {
status: 400,
body: "Please pass a name on the query string or in the request body"
};
return;
}
};
And don't forget to add queue output in function.json.
{
"disabled": false,
"bindings": [
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name": "req",
"methods": [
"get",
"post"
]
},
{
"type": "http",
"direction": "out",
"name": "res"
},
{
"type": "queue",
"direction": "out",
"name":"queueOutput" ,
"queueName": "azurequeue",
"connection":"AzureWebJobsStorage"
}
]
}
To avoid other obstacle in the future, have a look at Azure Function guidance of javascript.
answered Nov 14 at 1:48
Jerry Liu
9,0331628
add a comment |
Looks like you mix HttpTrigger and QueueTrigger together.
If you want to use your own logic above to write message to queue, make sure your function.json is like below.
{
"disabled": false,
"bindings": [
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name": "req",
"methods": [
"get",
"post"
]
},
{
"type": "http",
"direction": "out",
"name": "res"
}
]
}
If outputbinding feature provided by Azure function is preferred, let's use code below. No need to worry that azurequeue doesn't exist, output binding internally uses createQueueIfNotExists.
module.exports = async function (context, req) {
context.log('JavaScript HTTP trigger function processed a request.');
context.log('Request Headers = ' + JSON.stringify(req.headers));
if ((req.query.parameter && req.query.func) || (req.body && req.body.parameter && req.body.func)) {
var message = 'Hello world!'
var send = {'ans' : message};
return {
res: {
body: send
},
queueOutput: message
};
}
else {
context.res = {
status: 400,
body: "Please pass a name on the query string or in the request body"
};
return;
}
};
And don't forget to add queue output in function.json.
{
"disabled": false,
"bindings": [
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name": "req",
"methods": [
"get",
"post"
]
},
{
"type": "http",
"direction": "out",
"name": "res"
},
{
"type": "queue",
"direction": "out",
"name":"queueOutput" ,
"queueName": "azurequeue",
"connection":"AzureWebJobsStorage"
}
]
}
To avoid other obstacle in the future, have a look at Azure Function guidance of javascript.
answered Nov 14 at 1:48
Jerry Liu
9,0331628
add a comment |
Looks like you mix HttpTrigger and QueueTrigger together.
If you want to use your own logic above to write message to queue, make sure your function.json is like below.
{
"disabled": false,
"bindings": [
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name": "req",
"methods": [
"get",
"post"
]
},
{
"type": "http",
"direction": "out",
"name": "res"
}
]
}
If outputbinding feature provided by Azure function is preferred, let's use code below. No need to worry that azurequeue doesn't exist, output binding internally uses createQueueIfNotExists.
module.exports = async function (context, req) {
context.log('JavaScript HTTP trigger function processed a request.');
context.log('Request Headers = ' + JSON.stringify(req.headers));
if ((req.query.parameter && req.query.func) || (req.body && req.body.parameter && req.body.func)) {
var message = 'Hello world!'
var send = {'ans' : message};
return {
res: {
body: send
},
queueOutput: message
};
}
else {
context.res = {
status: 400,
body: "Please pass a name on the query string or in the request body"
};
return;
}
};
And don't forget to add queue output in function.json.
{
"disabled": false,
"bindings": [
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name": "req",
"methods": [
"get",
"post"
]
},
{
"type": "http",
"direction": "out",
"name": "res"
},
{
"type": "queue",
"direction": "out",
"name":"queueOutput" ,
"queueName": "azurequeue",
"connection":"AzureWebJobsStorage"
}
]
}
To avoid other obstacle in the future, have a look at Azure Function guidance of javascript.
answered Nov 14 at 1:48
Jerry Liu
9,0331628
Looks like you mix HttpTrigger and QueueTrigger together.
If you want to use your own logic above to write message to queue, make sure your function.json is like below.
{
"disabled": false,
"bindings": [
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name": "req",
"methods": [
"get",
"post"
]
},
{
"type": "http",
"direction": "out",
"name": "res"
}
]
}
If outputbinding feature provided by Azure function is preferred, let's use code below. No need to worry that azurequeue doesn't exist, output binding internally uses createQueueIfNotExists.
module.exports = async function (context, req) {
context.log('JavaScript HTTP trigger function processed a request.');
context.log('Request Headers = ' + JSON.stringify(req.headers));
if ((req.query.parameter && req.query.func) || (req.body && req.body.parameter && req.body.func)) {
var message = 'Hello world!'
var send = {'ans' : message};
return {
res: {
body: send
},
queueOutput: message
};
}
else {
context.res = {
status: 400,
body: "Please pass a name on the query string or in the request body"
};
return;
}
};
And don't forget to add queue output in function.json.
{
"disabled": false,
"bindings": [
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name": "req",
"methods": [
"get",
"post"
]
},
{
"type": "http",
"direction": "out",
"name": "res"
},
{
"type": "queue",
"direction": "out",
"name":"queueOutput" ,
"queueName": "azurequeue",
"connection":"AzureWebJobsStorage"
}
]
}
To avoid other obstacle in the future, have a look at Azure Function guidance of javascript.
answered Nov 14 at 1:48
Jerry Liu
9,0331628
edited Nov 14 at 2:00
answered Nov 14 at 1:48
Jerry Liu
9,0331628
answered Nov 14 at 1:48
Jerry Liu
9,0331628
answered Nov 14 at 1:48
Jerry Liu
9,0331628
9,0331628
add a comment |
add a comment |
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Some of your past answers have not been well-received, and you're in danger of being blocked from answering.
Please pay close attention to the following guidance:
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53280342%2fazure-queue-storage-message-not-getting-saved-in-the-right-queue-on-azure-functi%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
1
Instead of sharing screenshot of code, please share the actual code in question itself.
– Gaurav Mantri
Nov 13 at 11:46