読者です 読者をやめる 読者になる 読者になる

KZKY memo

自分用メモ.

Celery with Multiprocessing and SQLAlchemy

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

Flask x Celery

次の2つを含んだサンプル 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_…

Celery: Task Revoke

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…

Celery 基本

前提 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…