拉取
docker pull rabbitmq
启动
docker run -d -p 5672:5672 --name myrabbit rabbitmq
进入容器
docker exec -it myrabbit /bin/bash
查看用户
rabbitmqctl list_users
新增用户
rabbitmqctl add_user jw jw
提权
rabbitmqctl set_user_tags jw administrator
查看
abbitmqctl list_vhosts
增加
rabbitmqctl add_vhost myvhost
在提权
rabbitmqctl set_permissions -p myvhost jw ".*" ".*" ".*"
重启
docker restart myrabbit
使用
# 初始化flask
flask_app = init_app("application.settings.dev", 1)
# 加载配置
app.config_from_object("my_celery.config")
CELERY_BROKER_URL = 'amqp://yuan:%s@1.1.1.1:5672/myvhost' % parse.quote_plus("123456")
CELERY_RESULT_BACKEND = 'redis://1.1.1.1:6379/0'
# 追加配置
app.conf.update(
RESULT_EXPIRES=flask_app.app.config.get('CELERY_RESULT_EXPIRES'), # 结果存放倒计时
BROKER_URL=flask_app.app.config.get('CELERY_BROKER_URL'),
CELERY_RESULT_BACKEND=flask_app.app.config.get('CELERY_RESULT_BACKEND'),
TASK_IGNORE_RESULT=True,
)
