code: def feed_arthur():
      
  
      logger.info("Collecting items from redis queue")
  
      db_url = 'redis://localhost/8'
  
      conn = redis.StrictRedis.from_url(db_url)
      logger.debug("Redis connection stablished with %s.", db_url)
  
      # Get and remove queued items in an atomic transaction
      pipe = conn.pipeline()
      pipe.lrange(Q_STORAGE_ITEMS, 0, -1)
      pipe.ltrim(Q_STORAGE_ITEMS, 1, 0)
      items = pipe.execute()[0]
  
      for item in items:
          arthur_item = pickle.loads(item)
          if arthur_item['tag'] not in arthur_items:
              arthur_items[arthur_item['tag']] = []
          arthur_items[arthur_item['tag']].append(arthur_item)
  
      for tag in arthur_items:
          logger.debug("Items for %s: %i", tag, len(arthur_items[tag]))
docs: Feed Ocean with backend data collected from arthur redis queue