scrolls.importer module

class scrolls.importer.MessageImporter(dependencies)

Bases: object

Deals with newly arrived Messages

import_(messages)

Handles a batch of new messages

Will persist and aggregate them. If the batch is empty, will return immediately.

Args:

messages (list): List of Message objects to be imported.