python - Dificultad con el apio: objeto de función no tiene ''retraso'' de propiedad

python-2.7 flask

Question

He estado revolviendo el desarrollo de software recientemente y he tenido cierto éxito doblando el apio a mi voluntad.

Lo he utilizado con éxito para enviar correos electrónicos, y acabo de tratar de usar casi exactamente el mismo código (después de reiniciar todos los procesos, etc.) para enviar sms a través de Twilio.

Sin embargo, sigo recibiendo el siguiente problema:

File "/Users/Rob/Dropbox/Python/secTrial/views.py", line 115, in send_sms
send_sms.delay(recipients, form.text.data)
AttributeError: ''function'' object has no attribute ''delay''

Mi código es el siguiente:

@celery.task
def send_email(subject, sender, recipients, text_body):
    msg = Message(subject, sender=sender)
    for email in recipients:
        msg.add_recipient(email)
    msg.body = text_body
    mail.send(msg)

@celery.task
def send_sms(recipients, text_body):
    for number in recipients:
        print number
        num = ''+61'' + str(number)
        print num
        msg = text_body + ''this message to'' + num
        client.messages.create(to=num, from_="[phone]", body=msg)

send_email.delay cuando se llama desde mi views.py funciona perfectamente, sin embargo send_sms.delay falla cada vez que se produce el error anterior.

Cualquier ayuda para solucionar este problema es apreciada.

- Según lo solicitado:

@app.route(''/send_mail'', methods=[''GET'', ''POST''])
@roles_accepted(''Admin'')
def send_mail():
    form = SendMailForm(request.form)
    if request.method == ''POST'':
        if form.validate_on_submit():
            emails = db.session.query(User.email).all()
            list_emails = list(zip(*emails)[0]) 
            send_email.delay(''Subject'', ''[email protected]'', list_emails, form.text.data)
    return render_template(''send_generic.html'', form=form)

@app.route(''/send_sms'', methods=[''GET'', ''POST''])
@roles_accepted(''Admin'')
def send_sms():
    form = SendMailForm(request.form)
    if request.method == ''POST'':
        if form.validate_on_submit():
            recipients = db.session.query(User.mobile).all()
            list_recipients = filter(None, list(zip(*recipients)[0]))
            send_sms.delay(list_recipients, form.text.data)
    return render_template(''send_generic.html'', form=form, send_sms=send_sms)

Mi función send_sms apio decorado se muestra como una tarea registrada:

(env)RP:secTrial Rob$ celery inspect registered
-> [email protected]: OK
    * app.send_email
    * app.send_security_email
    * app.send_sms

y para config solo estoy usando el invitado: rabbitmq

CELERY_BROKER_URL = ''amqp://guest@localhost//''
CELERY_RESULT_BACKEND = ''amqp://guest@localhost//''

Answer 1

El nombre de vista send_sms entra en conflicto con el nombre de la tarea de apio. El nombre send_sms referencia a la vista, no a la tarea, cuando se usa en el módulo que contiene la vista.

Use un nombre diferente para evitar la sobrescritura.