App Engine development server не может выполнить поставленную в очередь задачу — без трассировки стека вообще

В настоящее время я пытаюсь поставить задачи в очередь в App Engine с помощью фреймворка Flask, но у меня возникли некоторые трудности. Я запускаю свой код, и кажется, что задачи поставлены в очередь должным образом, когда я проверяю сервер администратора на localhost:8000/taskqueue. Однако консоль повторно печатает следующую ошибку:

WARNING  2016-10-05 17:08:09,560 taskqueue_stub.py:1981] Task task1 failed to execute. This task will retry in 0.100 seconds

Кроме того, не похоже, что нужный код выполняется.

Мой вопрос в том, почему мой код не работает? Я извиняюсь за очень широкий вопрос, однако нет никакого следа стека, чтобы провести меня к чему-то более конкретному. Я упростил свой код, чтобы сделать мою ошибку воспроизводимой. Приведенный ниже код должен напечатать фразу «sample task» на консоли 5 раз. Однако этого не происходит.

#main.py

from google.appengine.api.taskqueue import taskqueue
from flask import Flask, Response

app = Flask(__name__)

@app.route("/get")
def get():
    for i in range(5):
        # attempt to execute the desired function 5 times
        # the message "sample task" should be printed to the console five times
        task = taskqueue.add(
            queue_name='my-queue',
            url='/sample_task',
        )
        message += 'Task {} enqueued, ETA {}.<br>'.format(task.name, task.eta)

    response = Response(message)
    return response

@app.route("/sample_task")
def sample_task():
    message = "sample task"
    print (message)
    return Response(message)


if __name__ == "__main__":
    app.run()

приложение.ямл

# app.yaml

runtime: python27
api_version: 1
threadsafe: true

# [START handlers]
handlers:
- url: /sample_task
  script: main.app
  login: admin

- url: /get
  script: main.app
  login: admin

очередь.ямл

# queue.yaml

queue:
- name: my-queue
  rate: 1/s
  bucket_size: 40
  max_concurrent_requests: 1

1 ответ

  1. Я нашел ответ здесь: https://stackoverflow.com/a/13552794

    По-видимому, все, что мне нужно сделать, это добавить метод POST к тому обработчику, который вызывается для очереди.

    Так

    @app.route("/sample_task")
    def sample_task():
    ...
    

    должно вместо быть:

    @app.route("/sample_task", methods=['POST'])
    def sample_task():
    ...