Подскажите примеры работы для pyhon + celery для уменьшения очереди insert в БД

Есть небольшое приложение на python, к нему прилетают данные с разной периодичностью. И сейчас эти данные сразу пишутся в БД mysql (insert делается по каждой порции). В какой-то момент, если слишком много данных, то вылетает ошибка, что с mysql слишком много подключений. Собственно хочется запихнуть эти порции в очередь celery и уже оттуда одним запросом insert 100-1000 записей делать. Хоть убейте не могу понять как правильно это сделать, т.к. уровень знания python - noob (((