blocks|key|1218059|text|如果您只需要调用API，而不考虑结果，您可以在另一个线程中使用Executor，这不会阻塞主线程。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1218060|要在Executor中运行，请在concurrent.futures的Executor中使用AbstractEventLoop.run_in_executor()。|offset|length|1218061|entityMap|0|LINK|mutability|MUTABLE|url|https://docs.python.org/3/library/concurrent.futures.html|1|https://docs.python.org/3/library/asyncio-eventloop.html#asyncio.AbstractEventLoop.run_in_executor^0|0|G|I|0|1A|Z|1|0^^$0|@$1|2|3|4|5|6|7|P|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|Q|8|@]|9|@$D|R|E|S|1|T]|$D|U|E|V|1|W]]|A|$]]|$1|F|3|-4|5|6|7|X|8|@]|9|@]|A|$]]]|G|$H|$5|I|J|K|A|$L|M]]|N|$5|I|J|K|A|$L|O]]]]

<p>If you just need to call the API, disregarding the result, you can use an Executor in another thread, which will not block the main thread.</p>

<p>To run in an Executor, use <a href="https://docs.python.org/3/library/asyncio-eventloop.html#asyncio.AbstractEventLoop.run_in_executor" rel="nofollow noreferrer">AbstractEventLoop.run_in_executor()</a> with an Executor from <a href="https://docs.python.org/3/library/concurrent.futures.html" rel="nofollow noreferrer">concurrent.futures</a>.</p>


blocks|key|898086|text|对于当前的示例，您需要在某个地方运行循环(例如，如果您有一些web服务器或worker+-+loop.run_forever())|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|898087|修复了运行循环的代码示例|898088|import+asyncio


async+def+callCoroutine(data):
++++print('This+is+data:+%25s'+%25+data)


def+lambda_handler(event,+context):+++
++++loop+=+asyncio.get_event_loop()
++++task+=+loop.create_task(callCoroutine(context))
++++return

lambda_handler(None,+{'a':+1})

loop+=+asyncio.get_event_loop()
loop.run_forever()|code-block|syntax|javascript|898089|使用run_in_executor()的示例|898090|import+asyncio
import+requests


def+call_rest_api(data):
++++print('Triggered+REST+API+in+background')
++++response+=+requests.get(data['url'])
++++print('Response:+%25s'+%25+response)


async+def+main(loop):
++++print('Some+operations+here...')

++++data+=+{'url':+'http://example.com#some_rest_api'}
++++loop.run_in_executor(None,+call_rest_api,+data)

++++print('Continue+work+of+main+thread...')


if+__name__+==+'__main__':
++++loop+=+asyncio.get_event_loop()
++++loop.run_until_complete(main(loop))|898091|简单接口示例(如果需要同步调用await+)|898092|但是，如果您想编写同步代码，则不需要使用asyncio。|898093|import+asyncio
import+requests


def+call_rest_api(data):
++++print('Triggered+REST+API+in+background')
++++response+=+requests.get(data['url'])
++++print('Response:+%25s'+%25+response)


async+def+main(loop):
++++print('Some+operations+here...')

++++data+=+{'url':+'http://example.com#some_rest_api'}
++++await+call_rest_api(data)

++++print('Continue+work+of+main+thread...')


if+__name__+==+'__main__':
++++loop+=+asyncio.get_event_loop()
++++loop.run_until_complete(main(loop))|898094|你能提供更详细的例子来说明你已经拥有什么和你想要实现什么吗？|898095|entityMap^0|1A|I|0|0|0|2|H|0|0|F|5|0|0|0|0^^$0|@$1|2|3|4|5|6|7|10|8|@$9|11|A|12|B|C]]|D|@]|E|$]]|$1|F|3|G|5|6|7|13|8|@]|D|@]|E|$]]|$1|H|3|I|5|J|7|14|8|@]|D|@]|E|$K|L]]|$1|M|3|N|5|6|7|15|8|@$9|16|A|17|B|C]]|D|@]|E|$]]|$1|O|3|P|5|J|7|18|8|@]|D|@]|E|$K|L]]|$1|Q|3|R|5|6|7|19|8|@$9|1A|A|1B|B|C]]|D|@]|E|$]]|$1|S|3|T|5|6|7|1C|8|@]|D|@]|E|$]]|$1|U|3|V|5|J|7|1D|8|@]|D|@]|E|$K|L]]|$1|W|3|X|5|6|7|1E|8|@]|D|@]|E|$]]|$1|Y|3|-4|5|6|7|1F|8|@]|D|@]|E|$]]]|Z|$]]

<p>For the current example, you need to have running loop somewhere (e.g. if you have some web-server or worker - <code>loop.run_forever()</code>)</p>

<h3>Fixed code example with running loop</h3>

<pre><code>import asyncio


async def callCoroutine(data):
    print('This is data: %s' % data)


def lambda_handler(event, context):   
    loop = asyncio.get_event_loop()
    task = loop.create_task(callCoroutine(context))
    return

lambda_handler(None, {'a': 1})

loop = asyncio.get_event_loop()
loop.run_forever()
</code></pre>

<h3>Example with <code>run_in_executor()</code></h3>

<pre><code>import asyncio
import requests


def call_rest_api(data):
    print('Triggered REST API in background')
    response = requests.get(data['url'])
    print('Response: %s' % response)


async def main(loop):
    print('Some operations here...')

    data = {'url': 'http://example.com#some_rest_api'}
    loop.run_in_executor(None, call_rest_api, data)

    print('Continue work of main thread...')


if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main(loop))
</code></pre>

<h3>Example with simple <code>await</code> (if you need to call API syncronously)</h3>

<p>But it is not necessary to use asyncio if you want to write synchronous code.</p>

<pre><code>import asyncio
import requests


def call_rest_api(data):
    print('Triggered REST API in background')
    response = requests.get(data['url'])
    print('Response: %s' % response)


async def main(loop):
    print('Some operations here...')

    data = {'url': 'http://example.com#some_rest_api'}
    await call_rest_api(data)

    print('Continue work of main thread...')


if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main(loop))
</code></pre>

<p>Can you provide more verbose example of what you have and what you want to achive?</p>


blocks|key|1218063|text|在您的示例中，主线程正在同步运行。因此，您需要使用asyncio.run_coroutine_threadsafe在另一个线程中运行异步循环。|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|1218064|import+asyncio
import+threading

#+Run+asyncio+loop+in+other+thread
loop+=+asyncio.new_event_loop()
threading.Thread(target=loop.run_forever).start()


async+def+call_coroutine(data):
++++#+call+a+REST+API+
++++return


def+lambda_handler(event,+context):+++
++++#+Run+the+coroutine+on+the+loop+of+other+thread
++++future+=+asyncio.run_coroutine_threadsafe(call_coroutine(data),+loop)
++++#+If+need+to+get+result:+
++++result+=+future.result()++#+This+will+block+the+main+thread

++++do_something_else()
++++return

#+If+need+to+stop+the+asyncio+loop
loop.call_soon_threadsafe(loop.stop)|code-block|syntax|javascript|1218065|entityMap|0|LINK|mutability|MUTABLE|url|https://docs.python.org/3/library/asyncio-task.html#scheduling-from-other-threads^0|P|W|0|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@$A|R|B|S|1|T]]|C|$]]|$1|D|3|E|5|F|7|U|8|@]|9|@]|C|$G|H]]|$1|I|3|-4|5|6|7|V|8|@]|9|@]|C|$]]]|J|$K|$5|L|M|N|C|$O|P]]]]

<p>In your case, the main thread is running synchronously.
So you need to run the asyncio loop in another thread Using <a href="https://docs.python.org/3/library/asyncio-task.html#scheduling-from-other-threads" rel="nofollow noreferrer">asyncio.run_coroutine_threadsafe</a>.</p>

<pre><code>import asyncio
import threading

# Run asyncio loop in other thread
loop = asyncio.new_event_loop()
threading.Thread(target=loop.run_forever).start()


async def call_coroutine(data):
    # call a REST API 
    return


def lambda_handler(event, context):   
    # Run the coroutine on the loop of other thread
    future = asyncio.run_coroutine_threadsafe(call_coroutine(data), loop)
    # If need to get result: 
    result = future.result()  # This will block the main thread

    do_something_else()
    return

# If need to stop the asyncio loop
loop.call_soon_threadsafe(loop.stop)
</code></pre>


<p>I am trying to call a REST API async using asyncio but i keep getting the error "<code>coroutine was never awaited</code>" which i understand. But i want this behavior, i want my function to end just by posting and not waiting for the result. Here is my code</p>

<pre><code>async def callCoroutine:
    #call a REST API 

def lambda_handler(event, context):   
    loop = asyncio.get_event_loop()
    task = loop.create_task(callCoroutine(data))
    return
</code></pre>

<p>Can someone help?</p>


python asyncio REST api call gives error

翻译质量差，导致语言生硬或混乱。

没有提供实际的解决方法或示例。

解答不清晰，无法理解或解决问题。

页面排版不美观，阅读体验差。

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

EdgeOne AI 安全实战专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

社区新版编辑器体验调研

我试图使用asyncio调用一个REST API async，但我一直收到错误"coroutine was never awaited“，这是我理解的。但是我想要这样的行为，我希望我的函数只通过发布而不是等待结果来结束。以下是我的代码async def callCoroutine:    #call a REST AP...

问python asyncio REST api调用出错
EN

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问python asyncio REST api调用出错EN