falcon api执行来自芹菜的任务

Question

在任务.py文件

from time import sleep

import celery


app = celery.Celery('tasks', broker='redis://localhost:6379/0', backend='redis://localhost:6379/0')


@app.task
def add(x, y):
    """
    :param int x:
    :param int y:
    :return: int
    """
    # sleep just for demonstration
    sleep(5)

    return x + y

我的猎鹰应用程序副本文件

^{pr2}$

外部api将传递参数以执行任务或通知任何其他建议的方法 现在这个纯在post调用中如何在falcon中使用get方法 我还有一个

import json
import requests
import falcon
from tasks import add
from celery.result import AsyncResult
import falcon
import json

class JSON_Middleware(object):
    def process_request(self, req, resp):
        raw_json = json.loads(req.stream.read().decode('UTF-8'))
        print req.content_length
        return raw_json

class Test:
    def on_post(self,req,resp):
        print raw_json
        pass

app = application = falcon.API(middleware=JSON_Middleware())
t = Test()
app.add_route('/test',t)

我怎样才能在post上使用原始json，或者我是在用一种不确定的方式来做呢

谢谢你的观看和回复 当做 新手