异步 def 和调用堆栈

Question

在 Python 3.6 中使用 asyncio 时，如果调用堆栈深处的一个函数是异步的，我是否需要使整个堆栈异步并在每次调用时都等待？
例如我有：

class FileDataSource:  
    def getData(self):  
        return pd.read_csv('/some/file')

class SocketDataSource:
    def __init__(self, host, port):
        self.reader, self.writer = yield from asyncio.open_connection(host, port)

    async def getData(self):
        data = await self.reader.readuntil(b'\n\n')
        return data

def func1(datasource):
    func2(datasource)

def func2(datasource):
    func3(datasource)

def func3(datasource):
    datasource.getData()

def main(host, port):
    if host is None:
        func1(FileDataSource())
    else:
        loop = asyncio.get_event_loop()
        for timeout in range(1, 60):
            loop.call_later(timeout, func1(SocketDataSource(host, port)))
        loop.run_forever()

1. 在上面的示例中，我是否需要将 func1 / 2 / 3 的整个调用堆栈设置为异步并等待所有它们？ （恐怕答案是肯定的）

2. 我可以将 FileDataSource 和 SocketDataSource 交替传递给 func1，还是需要根据异步调用和非异步调用更改整个调用层次结构？

3. 设计这样一个可以作为服务器或批处理运行的东西的最佳方法是什么？

非常感谢您的所有帮助！

Answer 1

如果调用堆栈深处的一个函数是异步的，我是否需要使整个堆栈异步并在每次调用时都等待？

答案取决于调用堆栈中的函数究竟做了什么，但很可能是的。 await effects 要求 async 函数与其调用者（等待者或事件循环驱动程序）通信，以确保暂停/恢复其执行。

一个非异步函数可以不等待就参与调用栈，但是它只能用于传输协程对象，不能检查数据。例如，func3 可以实现为：

async def func3(datasource):
    return await datasource.getData()

或：

def func3(datasource):
    return datasource.getData()

但第一个函数可以检查（或记录等）getData 返回的数据，而第二个函数立即退出并返回其他人必须等待的协程对象。

我可以将FileDataSource 和SocketDataSource 交替传递给func1，还是我需要根据异步调用和非异步调用更改整个调用层次结构？

一旦将调用堆栈中的所有函数设为异步，您将无法传递FileDataSource，但这并不意味着您必须拥有两个单独的调用层次结构。只需将def getData() 更改为async def getData()（否则保持实现不变），将FileDataSource 实现为简单的“异步”，只要它实际上没有阻塞，它将适用于异步使用。