- Asynchronous tasks (All the heavy lifting happens in the background, your users don't wait for it)
- Reusable components (You will need to make tradeoffs based on your use cases, Stream Framework doesn't get in your way)
- Full Cassandra and Redis support
- The Cassandra storage uses the new CQL3 and Python-Driver packages, which give you access to the latest Cassandra features.
- Build for the extremely performant Cassandra 2.1. 2.2 and 3.3 also pass the test suite, but no production experience.
This quick example will show you how to publish a "Pin" to all your followers. So let's create an activity for the item you just pinned.
from stream_framework.activity import Activity def create_activity(pin): activity = Activity( pin.user_id, PinVerb, pin.id, pin.influencer_id, time=make_naive(pin.created_at, pytz.utc), extra_context=dict(item_id=pin.item_id) ) return activity