By vsvconsult
I am trying to subscribe to a redis channel using aioredis (python) :
async def testAioredis(G):
if redisHost != 'localhost': #use digital ocean redis server
redis = await aioredis.create_connection((DOredisHost,DOredisPort), db=0
, password=DOredisPassword,ssl=True,timeout=1)
print(f'redis connection is to {DOredisHost}')
else: redis = await aioredis.create_redis(f'redis://localhost/0')
redis=redis.pubsub()
ch1, ch2 = await redis.subscribe('chan:1', 'chan:2')
print('subscribed')
This works if I set redisHost to ‘localhost’. If I try to use the DOManaged redis (DOredisHost,DOredisPort etc.), I get the error:
AttributeError: 'RedisConnection' object has no attribute 'subscribe'
The redis connection is made however. I tried a simple await redis.get(key) and that errored out the same way (no attribute ‘get’) Can you confirm that aioredis is suppored? Thx
This textbox defaults to using Markdown to format your answer.
You can type !ref in this text area to quickly search our full set of tutorials, documentation & marketplace offerings and insert the link!
Get paid to write technical tutorials and select a tech-focused charity to receive a matching donation.
Full documentation for every DigitalOcean product.
The Wave has everything you need to know about building a business, from raising funding to marketing your product.
Stay up to date by signing up for DigitalOcean’s Infrastructure as a Newsletter.
New accounts only. By submitting your email you agree to our Privacy Policy
Scale up as you grow — whether you're running one virtual machine or ten thousand.
Sign up and get $200 in credit for your first 60 days with DigitalOcean.*
*This promotional offer applies to new accounts only.