rabbitmq queue position check

queue_check.py

task_id = "change_this"  # TODO change this to your celery task ID
broker = "amqp://guest:guest@localhost/"  # TODO set this
MAX_QUEUE_CHECK = 20

try:
    connection = pika.BlockingConnection(pika.URLParameters(broker))
    channel = connection.channel()

    pos = -1
    for i, (_, properties, _) in enumerate(channel.consume("celery", inactivity_timeout=0)):
        if properties is None:
            break  # this means we've exhausted the queue
        if properties.headers["id"] == task_id:
            pos = i
            break
        if i >= MAX_QUEUE_CHECK - 1:
            pos = MAX_QUEUE_CHECK
            break  # we've checked as many as we're willing to

    channel.cancel()
    connection.close()
except pika.exceptions.AMQPError:
    logger.exception(f"Could not reach RabbitMQ: {broker}")
    return

if pos == -1:
    # Means the queue is empty, or the task ID was not in found in the queue
    pass
elif pos == MAX_QUEUE_CHECK:
    # Means we searched MAX_QUEUE_CHECK places in the queue, but still haven't found our task
    pass

does this remove the messages from the queue?

@netlob no, this leaves the message in the queue. However I have a newer version of this that speaks directly over the queue using the pika library.