How to Get all the pending tasks and purge queue in Pika RabbitMQ
I want to get all the pending tasks in the queue to save in database.
and remove those tasks from the queue.
I know channel.purgeQueue but it will only remove them.
I need to know the pending tasks in the queue.
How to get them
python rabbitmq queue pika
asked Nov 23 '18 at 14:04
Shan KhanShan Khan
3,25653470
add a comment |
I want to get all the pending tasks in the queue to save in database.
and remove those tasks from the queue.
I know channel.purgeQueue but it will only remove them.
I need to know the pending tasks in the queue.
How to get them
python rabbitmq queue pika
asked Nov 23 '18 at 14:04
Shan KhanShan Khan
3,25653470
add a comment |
I want to get all the pending tasks in the queue to save in database.
and remove those tasks from the queue.
I know channel.purgeQueue but it will only remove them.
I need to know the pending tasks in the queue.
How to get them
python rabbitmq queue pika
asked Nov 23 '18 at 14:04
Shan KhanShan Khan
3,25653470
I want to get all the pending tasks in the queue to save in database.
and remove those tasks from the queue.
I know channel.purgeQueue but it will only remove them.
I need to know the pending tasks in the queue.
How to get them
python rabbitmq queue pika
python rabbitmq queue pika
asked Nov 23 '18 at 14:04
Shan KhanShan Khan
3,25653470
asked Nov 23 '18 at 14:04
Shan KhanShan Khan
3,25653470
asked Nov 23 '18 at 14:04
Shan KhanShan Khan
3,25653470
asked Nov 23 '18 at 14:04
Shan KhanShan Khan
3,25653470
asked Nov 23 '18 at 14:04
Shan KhanShan Khan
3,25653470
3,25653470
add a comment |
add a comment |
1 Answer
1
active
oldest
votes
This is a basic RabbitMQ functionality, please read this:
https://www.rabbitmq.com/tutorials/tutorial-two-python.html
The code you are looking of is:
def callback(ch, method, properties, body):
print " [x] Received %r" % (body,)
### PUT_YOUR_CODE_HERE
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_consume(callback,
queue='hello')
When you execute the ch.basic_ack the message is removed from the queue
answered Nov 23 '18 at 14:59
GabrieleGabriele
14.7k42435
I want to run some function in the consumer when main purge is called in order to persist its messages.
– Shan Khan
Nov 23 '18 at 15:19
@ShanKhan is enough to put your code inside the callback, I modified the answer
– Gabriele
Nov 23 '18 at 15:45
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%2f53448147%2fhow-to-get-all-the-pending-tasks-and-purge-queue-in-pika-rabbitmq%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
This is a basic RabbitMQ functionality, please read this:
https://www.rabbitmq.com/tutorials/tutorial-two-python.html
The code you are looking of is:
def callback(ch, method, properties, body):
print " [x] Received %r" % (body,)
### PUT_YOUR_CODE_HERE
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_consume(callback,
queue='hello')
When you execute the ch.basic_ack the message is removed from the queue
answered Nov 23 '18 at 14:59
GabrieleGabriele
14.7k42435
I want to run some function in the consumer when main purge is called in order to persist its messages.
– Shan Khan
Nov 23 '18 at 15:19
@ShanKhan is enough to put your code inside the callback, I modified the answer
– Gabriele
Nov 23 '18 at 15:45
add a comment |
This is a basic RabbitMQ functionality, please read this:
https://www.rabbitmq.com/tutorials/tutorial-two-python.html
The code you are looking of is:
def callback(ch, method, properties, body):
print " [x] Received %r" % (body,)
### PUT_YOUR_CODE_HERE
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_consume(callback,
queue='hello')
When you execute the ch.basic_ack the message is removed from the queue
answered Nov 23 '18 at 14:59
GabrieleGabriele
14.7k42435
I want to run some function in the consumer when main purge is called in order to persist its messages.
– Shan Khan
Nov 23 '18 at 15:19
@ShanKhan is enough to put your code inside the callback, I modified the answer
– Gabriele
Nov 23 '18 at 15:45
add a comment |
This is a basic RabbitMQ functionality, please read this:
https://www.rabbitmq.com/tutorials/tutorial-two-python.html
The code you are looking of is:
def callback(ch, method, properties, body):
print " [x] Received %r" % (body,)
### PUT_YOUR_CODE_HERE
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_consume(callback,
queue='hello')
When you execute the ch.basic_ack the message is removed from the queue
answered Nov 23 '18 at 14:59
GabrieleGabriele
14.7k42435
This is a basic RabbitMQ functionality, please read this:
https://www.rabbitmq.com/tutorials/tutorial-two-python.html
The code you are looking of is:
def callback(ch, method, properties, body):
print " [x] Received %r" % (body,)
### PUT_YOUR_CODE_HERE
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_consume(callback,
queue='hello')
When you execute the ch.basic_ack the message is removed from the queue
answered Nov 23 '18 at 14:59
GabrieleGabriele
14.7k42435
edited Nov 23 '18 at 15:45
answered Nov 23 '18 at 14:59
GabrieleGabriele
14.7k42435
answered Nov 23 '18 at 14:59
GabrieleGabriele
14.7k42435
answered Nov 23 '18 at 14:59
GabrieleGabriele
14.7k42435
14.7k42435
I want to run some function in the consumer when main purge is called in order to persist its messages.
– Shan Khan
Nov 23 '18 at 15:19
@ShanKhan is enough to put your code inside the callback, I modified the answer
– Gabriele
Nov 23 '18 at 15:45
add a comment |
I want to run some function in the consumer when main purge is called in order to persist its messages.
– Shan Khan
Nov 23 '18 at 15:19
@ShanKhan is enough to put your code inside the callback, I modified the answer
– Gabriele
Nov 23 '18 at 15:45
I want to run some function in the consumer when main purge is called in order to persist its messages.
– Shan Khan
Nov 23 '18 at 15:19
I want to run some function in the consumer when main purge is called in order to persist its messages.
– Shan Khan
Nov 23 '18 at 15:19
@ShanKhan is enough to put your code inside the callback, I modified the answer
– Gabriele
Nov 23 '18 at 15:45
@ShanKhan is enough to put your code inside the callback, I modified the answer
– Gabriele
Nov 23 '18 at 15:45
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.
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%2f53448147%2fhow-to-get-all-the-pending-tasks-and-purge-queue-in-pika-rabbitmq%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
