Oejia 技术栈
首页
分享
微信模块
关于
编辑器
登录
Odoo 异步任务队列 task_queue 基于 celery 的使用
admin
on 2022-02-02
### 安装 - pip install celery==4.1.0 - pip install sqlalchemy (如果需要存储任务执行结果的话) - pip install redis (如果使用redis作为消息存储后端) ### 配置 在 odoo 的 conf 配置文件中可用的配置项: ```config # 消息存储后端 celery_broker_url = redis://localhost # redis://:e342dsf342543g5454@localhost # 是否存储任务执行结果 celery_result_backend_db = postgresql://openerp:openerp@localhost/dbname # 默认的队列 celery_default_queue = odoo # 可选队列 celery_queues = queue1, queue2, queue3 ``` ### Worker的运行 参考如下task_worker.py 代码: ```python # coding=utf-8 __import__('pkg_resources').declare_namespace('odoo.addons') import odoo from odoo.cli.shell import Shell args = ['-c', 'xxx.conf'] Shell().init(args) from odoo.addons.task_queue.tasks import * ``` 启动: `celery -A task_worker worker --loglevel=info` 扩展参数: `celery -A task_worker worker -c 1 -n s1@saas --loglevel=info` ### beat心跳的运行 通常为一个beat多个worker 启动: `celery -A task_worker beat --loglevel=info` ### Odoo中使用 ```python from odoo.addons.task_queue.api import Async @Aysnc() @api.model def func(self, a, b): pass @Aysnc(queue='queue1') @api.multi def func1(self, a, b): pass @Aysnc(queue='queue2') @api.one def func2(self, a, b): pass ``` 注意:确保方法的参数均为可序列化的python内置类型 在调用前如果异步任务执行时会引用到刚变动的记录请执行下数据库 commit 使变动确实生效 多进程worker同时跑时可能会出现odoo的事务错误,建议odoo中多使用autocommit=True的模式操作数据库
Information
Odoo 异步任务队列 task_queue 基于 celery 的使用
http://www.oejia.net/article/fe1e80ff03937d356de20bd9490809d0
http://www.oejia.net/raw/fe1e80ff03937d356de20bd9490809d0
admin
on 2022-02-02
Category
Odoo
Related
2016-03-14 :
关于 Odoo 的 dbfilter 配置项
2021-04-12 :
基于文件的带过期时间机制的key/value缓存实现
2016-03-19 :
从 odoo 源码看 odoo 8.0 到 9.0 的变化
2014-12-22 :
MoCrud详细说明文档
2016-02-01 :
odoo相关
2018-10-13 :
GUI自动化测试
2022-06-30 :
OE会员模块
2018-02-04 :
金融
2016-03-12 :
Odoo 的微信模块 Oejia_wx v0.2 发布!兼容 Odoo 9.0
2020-03-26 :
OE商城拼团、砍价模块
分类
(23)
Django (3)
DjangoX (13)
JS (2)
Nginx (1)
Odoo (126)
Python (1)
YouMd (3)
公告说明 (2)
前端 (2)
后端HTTP (7)
异常处理 (1)
桌面UI (1)
移动开发 (4)
官方公众号
关注公众号实时咨询我们
About This Entry
用 VIM 操作 BOM 标记
Odoo PoolError
About This Blog
main index
to find recently
archives
to find all
标签
微信模块发布记录
微信模块
小程序商城
Web
Http
客服系统
HTML5
审批OA
OE商城
Markdown
DjangoX
oeshop
服系统
解析
Excel
YouPBX
markdown
PyQT
md
Python
示例
最近发布
处理 Error Failed to download metadata for repo ‘appstream‘ Cannot prepare internal mirrorlist
Odoo 16 关键变化 change the term "acquirer" to "provider"
企业微信错误码 81013 的排查与处理
Odoo商城模块 Oejia_weshop v1.1 发布,支持Odoo16及下单子账号特性
微信模块 Oejia_wx v0.6.7 发布,支持 Odoo16 及新的Websocket消息模式
Odoo16 开启客屏时如何实现在POS设备上自动打开到第二屏
Odoo生产环境需要注意或修改的一些关键配置项
Odoo 更灵活的对账、付款及客户余额的介绍
Odoo16 SyntaxError
Friend Links
Oejia技术梦博客分享
YouMd,爱上MarkDown
Mole轻量级wsgi架子