celeryでMultiprocessingをするときにどういう挙動をするのか気になったので，調査． 1. 普通にMultiprocessing 2. SQLAlchemyでsessionを作ってから，Multiprocessing を検証する．1のコードはここ 2のコードはここ 普通にMultiprocessing AssertionError: …

次の２つを含んだサンプル Flaskの中からCelery Taskを実行する Celery Taskの中からdbにアクセスする flask_celery.py from celery import Celery from flask import Flask, request, jsonify from flask.ext.login import LoginManager, UserMixin, login_…

taskの中断 revokeを使う async_resultにアクセス可能なら，async_result.revoke() idのみわかっているなら，celery.task.control.revoke() worker.py from celery import Celery import time import celeryconfig #app = Celery("tasks", backend="rpc", br…

前提 OS: ubuntu14.04 インストール sudo apt-get install rabbitmq-server python-celery python-celery-doc 基本 celeryはmessage passing framework message brokerを必要とする Broker 選べる RabbitMQ Redis SQLAlchemy, Django Database (not recommen…