util.py 文件源码

def send_remote(self, url, data, headers=None, callback=None):
        headers = headers or {}
        if not self.state.should_try():
            message = self._get_log_message(data)
            self.error_logger.error(message)
            return

        async def _future():
            resp = await aiohttp.request('POST', url, data=data, headers=headers)
            await resp.release()

        asyncio.ensure_future(_future())