app = Celery('tasks', backend='amqp', broker='amqp://')
Or if you want to use Redis as the result backend, but still use RabbitMQ as the message broker (a popular combination):
app = Celery('tasks', backend='redis://localhost', broker='amqp://')
=========
Redis 命令行结果
127.0.0.1:6379> keys *
1) "emails"
2) "mmtest"
3) "_kombu.binding.celery"
4) "_kombu.binding.celeryev"
5) "celery-task-meta-f418abea-7827-4220-b72e-a0669e8b8a08"
6) "celery-task-meta-43105310-a8e2-483b-bd8a-8a54affc9192"
7) "_kombu.binding.celery.pidbox"
8) "name"
9) "unacked_mutex"
10) "email"
11) "mygmail"
12) "myyahoo"
如何产看redis里面的存储内容?
Cela peut en fait être considéré comme un problème Redis.
Utilisez la commande
type
pour afficher le type de données correspondant, puis utilisez d'autres commandes pour afficher le contenuPar exemple, pour les valeurs clés les plus élémentaires, utilisez
get $key
. Pourlist
, utilisezlrange
(puisque vous obtenez une plage, vous devez d'abord utiliserllen
pour obtenir la longueur en tant que paramètre).Bien entendu, il est également possible d'appeler les commandes pertinentes du client Redis sous Python.
Vous pouvez laisser Celery enregistrer les résultats de l'exécution de la tâche. Veuillez vous référer aux paramètres liés aux résultats ci-dessous.
http://docs.celeryproject.org...
result_backend
result_cache_max
result_compression
result_exchange
result_exchange_type
result_expires
result_persistent
result_serializer
Quant à la méthode de visualisation, en plus de naviguer directement dans le backend correspondant, vous pouvez également utiliser flower