Привет.

Постигаю асинхронный фукционал в третьей версии. Хочу задействовть в следующей задаче:
есть таск, который выполняет 3 функции: парсинг данных, его обработка и сохранение в базу. 
 def task(input_data):
    for i in input_data:
        data = parse(i)
        processed = process(data)
        save(processed)
Думаю сделать асинхронный парсинг и обработку на процессах. Собирать все в память, потом отправлять на процессинг не вариант. Наверно лучше через callback? Подскажите как лучше реализовать? Желательно с примерами. Спасибо.