import json
import pika

url = 'amqp://url/'
connection = pika.BlockingConnection(pika.URLParameters(url))
channel = connection.channel()

while True:
    method_frame, header_frame, body = channel.basic_get('default')
    if method_frame:
        if method_frame.message_count < 1000:
            break
        else:
            print(method_frame.message_count)
        body = json.loads(body.decode('utf8'))
        if body['task'] == 'plans.tasks.calculate_task_totals' or body['task'] == 'plans.tasks.calculate_aoi_totals':
            print('discarded')
            channel.basic_ack(method_frame.delivery_tag)
        else:
            print(body)
    else:
        break