大佬教程收集整理的这篇文章主要介绍了如何使用 redis 作为消息代理正确设置生产者 - 消费者方案并将结果存储在 postgresql / sqlite 中？，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。
我对 celery - redis 方案真的很陌生，但我正在尝试实现一个生产者-消费者 https://github.com/SkyBulk/celery 方案，类似于我的任务生产者是我的 Django 任务，然后是一个带有 celery beat 的代理（redis）对于任务调度程序，redis 可以适合这个方案来存储我的任务，芹菜工人执行任务生产者（django 任务）或任何其他外部 djngo 并将这些任务的结果保存到 sqlite 或 POSTGResql（不是调度程序的日志）>
demo
问题。为什么我在 redis 上什么也得不到？
@H_944_8@INSTALLED_APPS = [
"django.contrib.admin","django.contrib.auth","django.contrib.ContentTypes","django.contrib.sessions","django.contrib.messages","django.contrib.staticfiles","orders.apps.ordersConfig",]
CELERY_broKER_URL = "redis://redis:6379/0"
CELERY_RESulT_BACKEND = "redis://redis:6379/0"
CELERY_BEAT_scheDulE = {
"sample_task": {
"task": "orders.tasks.sample_task",'schedule': timedelta(seconds=2),},"send_email_report": {
"task": "orders.tasks.send_email_report","schedule": crontab(minute="*"),}
日志
@H_944_8@celery_1 | [2021-04-27 21:42:01,910: INFO/MainProcess] Received task: orders.tasks.sample_task[a50a9653-c141-4922-816a-67b9423bb110]
celery_1 | [2021-04-27 21:42:01,912: WARNING/ForkPoolWorker-3] each two seconds
celery_1 | [2021-04-27 21:42:01,913: INFO/ForkPoolWorker-3] Task orders.tasks.sample_task[a50a9653-c141-4922-816a-67b9423bb110] succeeded in 0.0017081940000025497s: None
celery_1 | [2021-04-27 21:42:03,910: INFO/MainProcess] Received task: orders.tasks.sample_task[567c8088-3de7-4876-a86f-ee418ff47ec5]
celery_1 | [2021-04-27 21:42:03,912: WARNING/ForkPoolWorker-3] each two seconds
celery_1 | [2021-04-27 21:42:03,913: INFO/ForkPoolWorker-3] Task orders.tasks.sample_task[567c8088-3de7-4876-a86f-ee418ff47ec5] succeeded in 0.0019250379999675715s: None
celery_1 | [2021-04-27 21:42:05,908: INFO/MainProcess] Received task: orders.tasks.sample_task[407d41a7-8b09-4760-94d8-9311f0e9222e]
celery_1 | [2021-04-27 21:42:05,909: WARNING/ForkPoolWorker-3] each two seconds
celery_1 | [2021-04-27 21:42:05,910: INFO/ForkPoolWorker-3] Task orders.tasks.sample_task[407d41a7-8b09-4760-94d8-9311f0e9222e] succeeded in 0.0009493900000165922s: None
celery_1 | [2021-04-27 21:42:07,910: INFO/MainProcess] Received task: orders.tasks.sample_task[87c00ebe-9353-46d9-9bd1-67c60280b937]
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）
以上是大佬教程为你收集整理的如何使用 redis 作为消息代理正确设置生产者 - 消费者方案并将结果存储在 postgresql / sqlite 中？全部内容，希望文章能够帮你解决如何使用 redis 作为消息代理正确设置生产者 - 消费者方案并将结果存储在 postgresql / sqlite 中？所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。