代码之家 › 专栏 › 技术社区 › Peter Pik

在api端点内发出http请求

tornado python-requests python

Peter Pik · 技术社区 · 8 年前

Async 不过,我想知道这种情况下的表现如何。如果 fetch 失败,我想输出一条消息。但既然是 异步 我想是的 self.finish _upload_to_nsq() 完成了吗?这里最好的方法是使其同步,或者如何改进代码以在错误期间输出消息?

class Handler(base.BaseHandler):

    def _upload_to_nsq(self):
        request = tornado.httpclient.HTTPRequest(
            '{}:4151/pub?topic=chamelo'.format(settings.nsqdlookup_address),
            body=self.request.body.decode(),
            method="POST")

        client = tornado.httpclient.AsyncHTTPClient()
        client.fetch(request)


    def _valiate_required_fields(self):
        missing_fields = []
        all_required_fields = ['state', 'upsert', 'schema']

        for field in all_required_fields:
            if field not in self.json_args:
                missing_fields.append(field)

        if len(missing_fields) > 0:
            raise FieldException('Require following fields: %s' % ', '.join(missing_fields))


    @tornado.web.removeslash
    def post(self):
        # Validate if required keys are present
        try:
            self._valiate_required_fields()
        except FieldException as e:
            self.set_status(400)
            self.finish({
            "code": 400,
                "message": str(e)
            })

        # Post request to nsqdlookup
        try:
            self._upload_to_nsq()
        except Error as e:
            self.set_status(400)
            self.finish({
            "code": 400,
                "message": str(e)
            })

        # Everything is good

        self.set_status(200)
        self.finish({
            "code": 200,
            "message": "Ok"
        })