gistfile1.py

def update_category(self, category_id):
        pipe = r.pipeline(True)
        category = Category.objects.get(pk=category_id)
        category_key = 'category::da::{}'.format(category.slug)
        data = [i for i in  category.products_category_related.filter(product__daproduct__online=True).order_by('-order_by').values('product', 'order_by').distinct()]
        products = DaProduct.extended.filter(pk__in=[i['product'] for i in data])
        self.readify([p.as_json for p in products])
        for p in data:
            key = 'product::da::{}'.format(p['product'])
            pipe.zadd(category_key, key, p['order_by'])
        pipe.execute()