0

我正在尝试实现 fire_and_forget 功能，这是详细信息。

我正在尝试使用的异步装饰器：

import asyncio
import time


def fire_and_forget(f):
    def wrapped(*args, **kwargs):
        return asyncio.get_event_loop().run_in_executor(None, f, *args, *kwargs)

    return wrapped

我的异步调用使用上面的装饰器：

@fire_and_forget
def call_async(self, req, body, headers_params):
    logger.info("Calling ASYNC")
    try:
        f = urllib.request.urlopen(req)
        response = f.read()
        f.close()
    except Exception as e:
        logger.exception("api exception %s" % e)
        return None

    # Parse and return the response
    try:
        res = self._parse_response(response)
    except Exception as e:
        logger.exception("Exception in parsing response of %s" % e)
        res = None
    logger.debug("clevertap response: {}".format(res))

我的 Flask 应用程序调用 test_xyz 反过来触发上述火灾并忘记 call_async：

from flask import Flask, jsonify, request
from call_xyz import test_xyz

app = Flask(__name__)

@app.route('/events_dm')
def events_dm():
    session_id = request.args.get('sessionId', "11111111")
    test_obj = test_xyz(session_id)
    test_obj.track_test()
    return jsonify({"success": True})


app.run(
            host='0.0.0.0',
            port=8091,
            debug=True,
            threaded=True
        )

我无法理解在哪里正确设置我的事件循环，因此我不会收到错误消息：“xyz 中的错误线程'Thread-7'中没有当前事件循环”并且我的事件被正确触发。

4

2 回答 2

0

您可能必须经历一次asyncio使用及其主要的心脏event loop理解。

类似的问题可能会帮助您理解。

这是带有一些很好解释的教程

只是给出一些关于如何coroutine与普通Flask应用程序一起使用的流程是示例之一。

import asyncio
import datetime

from flask import Flask, jsonify, request


app = Flask(__name__)

def print_now():
    print(datetime.datetime.now())


async def keep_printing(name: str="") -> None:
    print(name, end=" ")
    print_now()
    await asyncio.sleep(1.50)


async def main(num_times):
    result = await asyncio.gather(
        keep_printing("first"),
        keep_printing("second"),
        keep_printing("third"),
    )
    return result


def execute_statement():
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    loop.run_until_complete(main(2))
    loop.close()


@app.route('/events_dm')
def events_dm():
    execute_statement()
    return jsonify({"success": True})

app.run(
            host='0.0.0.0',
            port=8091,
            debug=True,
            threaded=True
        )

击中时输出/events_dm

first 2020-07-18 00:46:26.452921
second 2020-07-18 00:46:26.452921
third 2020-07-18 00:46:26.452921
127.0.0.1 - - [18/Jul/2020 00:46:27] "GET /events_dm HTTP/1.1" 200 -
于 2020-07-17T19:21:39.757 回答
0

Flask 与 asyncio 不兼容，因此您不应尝试在其中使用 asyncio。

此外，您实际上并没有使用 asyncio 的功能，而是run_in_executor调用了concurrent.futures，即在后台使用线程。如果这是您需要的，您可以直接创建一个执行器，然后将您的函数提交给它。例如：

import concurrent.futures
_pool = concurrent.futures.ThreadPoolExecutor()

def fire_and_forget(f):
    def wrapped(*args, **kwargs):
        return _pool.submit(lambda: f(*args, **kwargs))
    return wrapped
于 2020-07-17T19:05:24.200 回答