@app.task(base=Batches, flush_every=100, flush_interval=10)
def count_click(requests):
    from collections import Counter
count = Counter(request.kwargs['url'] for request in requests)
Celery Task Grouping/Aggregation