Frasco: pasando el trabajo del trabajador de fondo (rq, redis)

Question

Aug 28, 2012, 04:54 PM

session redis flask python backgroundworker

Frasco: pasando el trabajo del trabajador de fondo (rq, redis)

Quiero hacer una cosa muy simple: lanzar un trabajador a algo y luego devolver la respuesta al usuario. Estoy tratando de hacerlo usando una combinación de Flask y RQ.

import os
from flask import Flask, session
from somewhere import do_something
from rq import Queue
from worker import conn

app = Flask(__name__)
app.debug = True
app.secret_key = '....'

q = Queue(connection=conn)

@app.route('/make/')
def make():
    job = q.enqueue(do_something, 'argument')
    session['job'] = job
    return 'Done'

@app.route('/get/')
def get():
    try:
        session['job'].refresh()
        out = str(session['job'].result)
    except:
        out = 'No result yet'
    return out

La idea en este ejemplo muy simple es que las personas van a / make / y el trabajo comienza. Después de un tiempo, puede ir a / obtener / y el resultado del trabajador se imprimirá allí.

Sin embargo, una línea está causando problemas:

session['job'] = job

Parece que el trabajo no puede ser decapado, lo que aparentemente se usa en la sesión de Flaks. Estoy recibiendo el error:

...
10:52:16 web.1     |   File "/Users/julius/twitter-sentiment/venv/lib/python2.7/site-packages/flask/app.py", line 804, in save_session
10:52:16 web.1     |     return self.session_interface.save_session(self, session, response)
10:52:16 web.1     |   File "/Users/julius/twitter-sentiment/venv/lib/python2.7/site-packages/flask/sessions.py", line 205, in save_session
10:52:16 web.1     |     secure=secure, domain=domain)
10:52:16 web.1     |   File "/Users/julius/twitter-sentiment/venv/lib/python2.7/site-packages/werkzeug/contrib/securecookie.py", line 329, in save_cookie
10:52:16 web.1     |     data = self.serialize(session_expires or expires)
10:52:16 web.1     |   File "/Users/julius/twitter-sentiment/venv/lib/python2.7/site-packages/werkzeug/contrib/securecookie.py", line 235, in serialize
10:52:16 web.1     |     self.quote(value)
10:52:16 web.1     |   File "/Users/julius/twitter-sentiment/venv/lib/python2.7/site-packages/werkzeug/contrib/securecookie.py", line 192, in quote
10:52:16 web.1     |     value = cls.serialization_method.dumps(value)
10:52:16 web.1     |   File "/Users/julius/twitter-sentiment/venv/bin/../lib/python2.7/copy_reg.py", line 70, in _reduce_ex
10:52:16 web.1     |     raise TypeError, "can't pickle %s objects" % base.__name__
10:52:16 web.1     | TypeError: can't pickle function objects

Realmente espero que algo pueda ayudar. Puede que esté haciendo esto de una manera completamente incorrecta (al pasar el trabajo a través de una sesión), pero no tengo idea de cómo acceder al resultado del trabajo ...

Cualquier ayuda será muy apreciada.

Gracias por adelantado.

Deja tu comentario