Stream Framework is a Python library, which allows you to build news feed, activity streams and notification systems using Cassandra and/or Redis. The authors of Stream-Framework also provide a cloud service for feed technology:
ImportError: cannot import name 'BasePipeline' from 'redis.client' (/home/ian/.local/lib/python3.8/site-packages/redis/client.py)
ian@ian-HP-Stream-Laptop-11-y0XX:~/stream-framework/Stream-Framework$ python3
Python 3.8.10 (default, Sep 28 2021, 16:10:42)
[GCC 9.3.0] on linux
Type "help", "copyright", "credits" or "license" for more information.
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
...
from stream_framework.feeds.redis import RedisFeed
Traceback (most recent call last):
File "", line 1, in
File "/home/ian/stream-framework/Stream-Framework/stream_framework/feeds/redis.py", line 2, in
from stream_framework.storage.redis.activity_storage import RedisActivityStorage
File "/home/ian/stream-framework/Stream-Framework/stream_framework/storage/redis/activity_storage.py", line 2, in
from stream_framework.storage.redis.structures.hash import ShardedHashCache
File "/home/ian/stream-framework/Stream-Framework/stream_framework/storage/redis/structures/hash.py", line 1, in
from stream_framework.storage.redis.structures.base import RedisCache
File "/home/ian/stream-framework/Stream-Framework/stream_framework/storage/redis/structures/base.py", line 2, in
from redis.client import BasePipeline
ImportError: cannot import name 'BasePipeline' from 'redis.client' (/home/ian/.local/lib/python3.8/site-packages/redis/client.py)
ImportError: cannot import name 'BasePipeline' from 'redis.client' (/home/ian/.local/lib/python3.8/site-packages/redis/client.py)
ian@ian-HP-Stream-Laptop-11-y0XX:~/stream-framework/Stream-Framework$ python3 Python 3.8.10 (default, Sep 28 2021, 16:10:42) [GCC 9.3.0] on linux Type "help", "copyright", "credits" or "license" for more information.