tbarbugli
commented
10 years ago your settings looks ok, can you add the version of celery you running and the command you are using to start the worker ?
2014/1/8 Andreas Røed notifications@github.com
Hi again! Im working on a django project (more info in issue #16https://github.com/tschellenbach/Feedly/issues/16) I've got my Celery worker up and running, my redis seems database ok and most of my setup seems fine.. The only problem is that when I try to "fanout" to new feeds, the feeds does not seem to reach the Celery worker.. (seems no tasks are added to the worker queue). I know this might be a broker/worker issue, but I haven't found any good indications of what the problem might be :( Everything works fine when CELERY_ALWAYS_EAGER == True , so I don't think there is a problem with my code..
for feedly to work properly with celery and redis the things I would need is a Celery worker running, redis db setup ok, and a task broker (redis or rabbitmq) , right? I think I lack the understanding of how the broker and worker works together with feedly..?
Any tips are much appreciated :)
Adding to feed: activity = Activity(wishlist.user,WishVerb,in_prod.id) feed = UserWishFeed(wishlist.user.id) feed.insert_activity(activity) feed.add(activity) feedly.add_wish(wishlist.user, activity)
A view for fetching friends-feed : @csrf_exempt @api_view(['GET']) @login_required def friends_wish_feed(request, _args, *_kwargs): user = GiftItEndUser.objects.get(pk=kwargs['pk']) if request.user.id != user.pk: content = {"message":"you do not have permission","status":0} json_data = json.dumps(content) return Response(json_data)
feed = feedly.get_feeds(request.user.id)['normal'] act_list = [] json_data = [] activities = list(feed[:25]) for act in activities: act = {'user_id':act.actor_id,'product_id':act.object_id} act_list.append(act) json_data = json.dumps(act_list) return Response(json_data)Some celery settings: FEEDLY_NYDUS_CONFIG = { 'CONNECTIONS': { 'redis': { 'engine': 'nydus.db.backends.redis.Redis', 'router': 'nydus.db.routers.redis.PrefixPartitionRouter', 'hosts': { 0: {'prefix': 'default', 'db': 0, 'host': '127.0.0.1', 'port': 6379}, } }, } }
BROKER_URL = 'redis://localhost:6379/0' CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
— Reply to this email directly or view it on GitHubhttps://github.com/tschellenbach/Feedly/issues/20 .
andrenro
Hi again! Im working on a django project (more info in issue #16 ) I've got my Celery worker up and running, my redis seems database ok and most of my setup seems fine.. The only problem is that when I try to "fanout" to new feeds, the feeds does not seem to reach the Celery worker.. (seems no tasks are added to the worker queue). I know this might be a broker/worker issue, but I haven't found any good indications of what the problem might be :( Everything works fine when CELERY_ALWAYS_EAGER == True , so I don't think there is a problem with my code..
for feedly to work properly with celery and redis the things I would need is a Celery worker running, redis db setup ok, and a task broker (redis or rabbitmq) , right? I think I lack the understanding of how the broker and worker works together with feedly..?
Any tips are much appreciated :)
Adding to feed: activity = Activity(wishlist.user,WishVerb,in_prod.id) feed = UserWishFeed(wishlist.user.id) feed.insert_activity(activity) feed.add(activity) feedly.add_wish(wishlist.user, activity)
A view for fetching friends-feed : @csrf_exempt @api_view(['GET']) @login_required def friends_wish_feed(request, _args, *_kwargs): user = GiftItEndUser.objects.get(pk=kwargs['pk']) if request.user.id != user.pk: content = {"message":"you do not have permission","status":0} json_data = json.dumps(content) return Response(json_data)
Some celery settings: FEEDLY_NYDUS_CONFIG = { 'CONNECTIONS': { 'redis': { 'engine': 'nydus.db.backends.redis.Redis', 'router': 'nydus.db.routers.redis.PrefixPartitionRouter', 'hosts': { 0: {'prefix': 'default', 'db': 0, 'host': '127.0.0.1', 'port': 6379}, } }, } }
BROKER_URL = 'redis://localhost:6379/0' CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'