在探索Python3.4.0的异步模块时，我尝试使用类外部的asyncio.coroutine方法创建一个类。
我的工作代码在下面。
import asyncio
class Foo():
@asyncio.coroutine
def async_sleep(self):
print('about to async sleep')
yield from asyncio.sleep(1)
@asyncio.coroutine
def call_as(self):
print('about
浏览 3提问于2014-04-25得票数 5
回答已采纳
1回答
我尝试在Python 3.6上的Python 3.6应用程序中使用异步原始套接字，对于来自curio的异步函数在sanic异步上下文中不能工作感到非常惊讶。概念的最小证明：
import curio
from sanic import Sanic
from sanic.response import text
app = Sanic(__name__)
@app.route('/')
async def index(request):
sock = await curio.open_connection("google.com", 443, ssl=
浏览 1提问于2017-04-17得票数 1
回答已采纳
我正在尝试使用Python Websockets库构建一个服务器和客户端。我遵循这里给出的例子：Python OCPP documentation。我想编辑这个例子，这样对于每个新的客户端(Charge Point)，服务器(中央系统)在新的线程(或新的循环，因为Websockets库使用Python的异步)上运行。基本上，我希望同时从多个客户端接收消息。我修改了服务器(中央系统)的main方法，从我遵循的例子开始，像这样在websockets.serve()中添加了一个循环参数，希望每当有新的客户端运行时，它都会运行在不同的循环上： async def main():
server
浏览 189提问于2020-04-26得票数 0
回答已采纳
我有一个带有嵌入式python解释器的C++二进制文件，它是通过完成的。
它还具有许多使用的tcp连接，这些连接使用专有的消息传递协议，并根据消息内容更新某些状态。
在启动时，我们导入一个python模块，在其中实例化一个特定的类，并获得该类中各种回调方法的pybind11::py_object句柄。
namespace py = pybind11;
class Handler
{
public:
Handler(const cfg::Config& cfg)
: py_interpreter_{std::make_unique<py::scoped_i
浏览 27提问于2022-02-11得票数 2
回答已采纳
我正试着在Jupyter上运行justpy web应用程序，比如下面这个：
import justpy as jp
def hello_world():
wp = jp.WebPage()
d = jp.Div(text='Hello world!')
wp.add(d)
return wp
jp.justpy(hello_world)
但无论我是在Jupyter Notebook上运行还是在Jupyter Lab上运行，这都会产生错误：
----------------------------------------------------
浏览 4提问于2021-04-02得票数 1
我只是简单地将tornado应用程序与线程结合使用，如下所示：
def MakeApp():
return tornado.web.Application([(r"/websocket", EchoWebSocket), ])
def run_tornado_websocket():
app = MakeApp()
http_server = tornado.httpserver.HTTPServer(app, ssl_options={
"certfile": os.path.join(os.path.abspath(
浏览 1提问于2018-06-26得票数 3
这是简单的测试代码和结果。
import asyncio
async def test():
await asyncio.sleep(1)
if __name__ == '__main__':
asyncio.set_event_loop(None) # Clear the main loop.
loop = asyncio.new_event_loop() # Create a new loop.
loop.run_until_complete(test()) # Run coroutine over the new l
浏览 0提问于2018-02-04得票数 8
回答已采纳
我试图在Windows上测试一些异步功能。我正在使用Python3.7。
这令人痛心地抱怨一些NotImplementedError
import asyncio
import os
import time
import sys
#this works
async def say_after(delay, what):
await asyncio.sleep(delay)
print(what)
#this doesn't
async def test_async(num):
print('Task #{0} start'.format(nu
浏览 1提问于2018-11-03得票数 1
回答已采纳
我有一个简单的websocket服务器，它可以将相机帧提供给电子应用程序。代码主要取自。这样做的想法是，当我打开websocket时，python将启动一个while循环，该循环不断地发送将被js 'client‘捕获的帧。然而，为了能够停止这个while循环，我需要在一个执行器上运行这个方法，因为否则它会被卡在里面。只要没有设置事件，并且这个事件是在websocket的on_close方法上设置的，循环就应该运行。
我做了一个单独的方法来模拟相机，在实际的应用程序中，帧来自另一个过程。
问题是，在运行程序一段时间后，我的日志被以下内容淹没:ERROR:异步:Task已被销毁，但它正在
浏览 0提问于2019-09-04得票数 1
回答已采纳
我找不到如何在预先存在的OpenGL上下文中使用wxPython。我知道如何单独使用wxPython并创建自己的窗口，但是可以使用窗口使用的上下文吗？
因此，我有一个使用OpenGL的用c++编写的引擎。我正在计划一个使用python的ui元素。我打算将python与c++链接起来(这应该没有问题)，但是是否可以在python部分中使用wxPython，并使其使用先前存在的窗口中的OpenGL上下文？
编辑:对于那些以前尝试过的人来说，可以工作吗？
浏览 1提问于2014-08-22得票数 1
这是我编写的一个小测试程序，试图了解如何将PyQt事件循环与asyncio一起使用。
import sys
from PyQt5.QtWidgets import QApplication, QMainWindow, QPushButton
from PyQt5 import QtCore
import qasync
import asyncio
async def main():
app = QApplication(sys.argv)
asyncio.set_event_loop(qasync.QEventLoop(app))
window = QMainWind
浏览 21提问于2021-07-18得票数 1
回答已采纳
1回答
我有这个代码，理论上，它将检查一个通道中发送了多少条消息，并在每天的某个时间执行此操作。代码如下：
def checkTime():
# This function runs periodically every 1 second
threading.Timer(1, checkTime).start()
now = datetime.now()
current_time = now.strftime("%H:%M:%S")
print("Current Time =", current_time)
if(c
浏览 1提问于2021-03-28得票数 0
1回答
我正在学习Python中的异步。有一种困惑，我不能把我的头绕过去。
假设我有两个Python脚本:tumy1.py和tumy2.py。在第一个脚本中，我的代码如下所示：
loop = asyncio.get_event_loop()
loop.create_task(a_task)
第一个脚本将导入到第二个脚本中，在第二个脚本中，我将我的代码安排如下：
loop = asyncio.get_event_loop()
loop.run_forever()
是否创建了两个不同的事件循环？谢谢你们的时间伙计们！
浏览 0提问于2021-12-04得票数 1
回答已采纳
如果我在python3解释器上运行这个程序：
import asyncio
@asyncio.coroutine
def wait(n):
asyncio.sleep(n)
loop = asyncio.get_event_loop()
fut = asyncio.async(wait(10))
fut.add_done_callback(lambda x: print('Done'))
asyncio.Task.all_tasks()
我得到以下结果：
{<Task pending coro=<coro() running at /usr/local
浏览 3提问于2015-08-08得票数 5
回答已采纳
我正在尝试使用库，但我得到了RuntimeError: Event loop is closed。
这是我的代码和回溯。
代码
import asyncio
import asyncpraw
async def main():
reddit = asyncpraw.Reddit('praw_ini_name')
print('User is', await reddit.user.me())
await reddit.close()
asyncio.run(main())
回溯
User is python_user
Exceptio
浏览 4提问于2021-02-28得票数 3
回答已采纳
1回答
我正在开发一个Python应用程序(使用Eel)，该应用程序使用Twisted反应堆不断调用网络连接的RFID读取器。收集到的数据需要被解析，GUI需要更新。
在这个循环中，GUI也需要响应，它能够使用从Eel的JS前端传递的函数调用来停止连接。下面是代码现在的简化版本：
def callback(RFID_tag):
print(RFID_tag)
@eel.expose
def stopInventory():
reactor.stop()
@eel.expose
def startInventory():
RFID_factory = <SETTING
浏览 7提问于2022-02-18得票数 0
回答已采纳
我们将wxPython嵌入到现有的c++ wxWidgets应用程序中。并使用pyshell/pyshell以交互方式将python命令输入到应用程序。它工作得很好，除了当应用程序弹出一个模式对话框时，我们不能在pyshell/pyshell中进行任何输入。有什么办法可以解决这个问题吗？
浏览 0提问于2013-12-27得票数 0
Python中的实现接口在哪里，它允许异步循环运行程序(来自trio、异步、curio)启动整个系统？
我们知道同步函数不能调用异步函数，但是异步实现有一个启动整个事件循环的神奇函数，例如：
trio.run(some...async...fun)...
docstring: except that :func:`run` can (and must) be called from a synchronous context.
谷歌搜索'python启动一个异步事件循环‘是指异步文档，这是一个特定的实现。
异步/trio/curio循环运行器是否都是手工创建的，以打破同步->异
浏览 0提问于2019-07-11得票数 1
1回答
我正在尝试从Rasa-x对我的amazon海王星数据库进行一个简单的查询。 下面是我的actions.py中的代码： class ActionQueryDietary(Action):
def name(self) -> Text:
return "action_query_dietary"
def run(self, dispatcher: CollectingDispatcher, tracker: Tracker, domain: Dict[Text, Any]) -> List[Dict[Text, Any]]:
浏览 37提问于2020-10-23得票数 0
回答已采纳
1回答
我们使用的是 (Flask+asyncio) Python框架。每次处理请求并将响应发送到客户端时，都会记录此消息(或类似消息)：
警告:异步:执行<任务挂起的名称=‘Task-11’coro=<ASGIHTTPConnection.handle_request()，运行在/usr/local/lib/python3.8/asyncio/base_events.py:422> cb=_wait.._on_completion() at /usr/local/lib/python3.8/asyncio/tasks.py:在/usr/local/lib/python3.8/si
浏览 3提问于2021-12-22得票数 2
回答已采纳
3回答
非阻塞django？
、、、、
在工作中，我不允许将perl用于web服务。但是，允许使用Python。
我需要做的是提供一些非常慢的c++二进制文件的结果。每个exe运行时间长达20秒。在perl中，我只使用mojolicious的非阻塞事件循环(这里给出了一个example.of。 )
如何使用django和python来做到这一点呢？
浏览 2提问于2014-01-26得票数 10
1回答
Windows环境下的剧作家集成
、、、、
我正在尝试使用库来解析/抓取基于JavsScript的网站。在工作期间，我了解到这与windows系统不兼容。我在这里提出最低限度的可复制性
import scrapy
from asyncio.windows_events import *
from scrapy.crawler import CrawlerProcess
class Play1Spider(scrapy.Spider):
name = 'play1'
def start_requests(self):
yield scrapy.Request("http://
浏览 31提问于2022-07-12得票数 0
因此，我一直试图创建一个运行后台服务器的进程，并使用守护进程启动它。所以我的代码是：
class App():
def __init__(self):
self.stdin_path = '/dev/null'
self.stdout_path = '/dev/tty'
self.stderr_path = '/dev/tty'
self.pidfile_path = '/tmp/foo.pid'
self.pidfile_timeout = 5
def run(self):
浏览 2提问于2012-07-20得票数 3
我目前正在进行一个项目，在那里我正在寻找信息更新，然后将状态消息发布到一个松弛的通道。这是我的第一个python项目，我对出了什么问题有点不知所措。但是，我得到的RuntimeError: There is no current event loop in thread 'MainThread'错误似乎是由我的主函数中有两个异步请求引起的。
我想知道是否有人能告诉我什么是最佳实践，我怎样才能避免更多的问题？
def main():
configure()
print("the project has started")
asyncio.
浏览 12提问于2022-03-16得票数 2
# !/usr/bin/python3
import asyncio
import aiohttp
from threading import Thread
event_loop = asyncio.get_event_loop() # getting the event_loop
Thread(target=event_loop.run_forever).start() # creating one more thread(to add and then to execute tasks when it is necessary)
async def fetch(session,
浏览 1提问于2020-07-17得票数 1
我在python2.7中使用Tkinter，我注意到有时根窗口直到我启动mainloop方法才会打开。此外，在这些情况下，当关闭窗口时，程序将结束( root.mainloop是代码中的最后一行)，而在其他情况下，它不会发生。
为什么会发生这种情况？
浏览 1提问于2018-11-24得票数 1
1回答
我有这个js代码：
const python = spawn('python', [path.join(settings.PROJECT_DIR, '/tests_explorer/scripts/product/product.py').replace(/\\/g, "/"), 'node.js', 'python']);
python.stdout.on('data', function (data) {
console.log('Pipe data from python scr
浏览 5提问于2021-09-26得票数 0
我正在尝试用Python制作一个Discord机器人，它会根据您所在的班级(在我的学校)为您提供Discord服务器上的角色。我刚开始，但每当我尝试运行它时都会收到一个错误(我在Python 3 Notebook中的Google Colab中运行它)。下面是我的代码：
from datetime import date
import time
import discord
client = discord.Client()
@client.event
async def on_ready():
print('We have logged in as {0.user}'
浏览 1提问于2020-01-24得票数 0
在我完成关于乌龟ORM的章节之前，我学会了烧瓶。我试着把烧瓶和乌龟结合起来，却找不到合适的方法。当我调用异步函数时，我得到了错误：
Traceback (most recent call last):
File "C:\Users\Vladlen\python\pythonBasics\venv\lib\site-packages\flask\app.py", line 2464, in __call__
return self.wsgi_app(environ, start_response)
File "C:\Users\Vladlen\python
浏览 1提问于2020-10-19得票数 0
回答已采纳
1回答
我对python中的异步编程很陌生，我正在编写一个脚本，它启动websocket服务器，侦听消息，并在gtk窗口中触发某些事件(例如按下键)时发送消息。到目前为止，我的情况如下：
import gi
gi.require_version('Gtk', '3.0')
from gi.repository import Gtk
import asyncio
import websockets
import threading
ws = None
async def consumer_handler(websocket, path):
global ws
浏览 1提问于2018-04-16得票数 2
回答已采纳
问题
在我自己的项目中，我在线程中启动一个事件循环，然后取消任务并安全地关闭另一个线程中的循环。但我失败了。
在阅读了之后，我仍然无法理解如何等待Task.cancel之后真正取消的任务
Python版本:3.7.1
操作系统: windows
下面是我的调试过程。
import threading
import asyncio
import time
async def visit_sth():
print("start sleep")
await asyncio.sleep(3)
print("end sleep")
class
浏览 1提问于2018-12-18得票数 2
我有一个简单的测试，使用run_forever方法运行Python异步事件循环，然后在另一个线程中立即停止它。但是，事件循环似乎没有终止。我有以下测试用例：
import asyncio
from threading import Thread
loop = asyncio.get_event_loop()
thread = Thread(target=loop.run_forever)
thread.start()
print('Started!')
loop.stop()
print('Requested stop!')
thread.join()
pri
浏览 0提问于2017-09-07得票数 17
回答已采纳
1回答
我希望使用PyQt4 (信号/插槽、线程、进程和其他核心模式)创建python服务器应用程序。
我怎么能创造这个？
浏览 2提问于2015-06-03得票数 2
回答已采纳
在木星笔记本(python3.6.1)中，我在(18.5.3.1.1 )中运行了基本的python Hello_World。例如：)，注意到它给了我一个RuntimeError。在尝试了很长一段时间来发现程序的问题(我的理解是，这些文档可能并不完全是最新的)之后，我终于注意到它只在第二次运行之后才这样做，并在重新启动的内核中进行了测试。从那时起，我在两个连续的单元格中复制了相同的小python程序(在1和2中)，发现它在第二个单元格上给出了错误，而不是第一个单元格，然后给出了两个单元格的错误。这将在重新启动内核之后重复此操作。
import asyncio
def hello_world(l
浏览 1提问于2017-04-28得票数 2
回答已采纳
我有一个QGLWidget，其中创建了openGL对象。我想得到比现在更好的抗混叠，使用glutInitDisplayMode(GLUT_DOUBLE、GLUT_MULTISAMPLE、GLUT_MULTISAMPLE、GLUT_DEPTH)。如何实现这个函数(在python中)？
浏览 1提问于2014-04-09得票数 1
回答已采纳
1回答
我被困在该做什么上了。我有一个while循环让xlib在我的Qt应用程序不在焦点时读取按键。这是从ubuntu16.04python3-xlib包/usr/share/doc/python3-xlib/examples/record_demo.py.中复制粘贴的但这破坏了Qt应用程序的功能，因为它只读取按键，而不处理Qt的事件循环。我应该让我的Qt应用程序有第二个线程吗？或者，我可以将xlib的循环挂接到Qt的循环上吗？
我正在使用python3、pyqt5和python3-xlib。
下面是文件/usr/share/doc/python3-xlib/examples/record_demo.
浏览 0提问于2016-12-06得票数 0
我正在尝试运行多个不和谐机器人与同一脚本一次。我这样做的方式是进入一个csv文件，以获得机器人令牌和机器人名称。然后启动我的脚本： import time, csv, re, random, string, sys, os, asyncio
from datetime import datetime
from threading import Thread
import discord
from dotenv import load_dotenv
from discord_webhook import DiscordWebhook, DiscordEmbed
def main(bottok
浏览 148提问于2020-11-08得票数 1
回答已采纳
1回答
首先，我为我的英语道歉。我正在学习python异步模块，有些时候我会感到困惑。我从文档中了解到，事件循环的主要目的是为运行调度协同，打开newtwork I/O。运行中的协同线可以通过等待自身来将控制返回到事件循环，所以如果我错了，那么如果我错了，要使上面的操作成为可能，需要始终在主线程上运行事件循环吗？如果是这样的话，异步如何管理在同一线程上同时运行事件循环和协同线？也许有一种机制可以挂起事件循环，并在需要时恢复它？或者事件循环是否有一个专用线程(我不确定)？
浏览 4提问于2022-08-22得票数 5
回答已采纳
我正在尝试使用google.cloud.firestore.AsyncClient模块对firebase进行一些API调用。Fire2只是这个对象的包装器。 回溯表明这是asyncio的一个问题，但如果我做一个虚拟的等待，它实际上运行得很好。问题是什么?为什么会出现问题？ 示例代码： import Fire2
class Test:
def __init__(self):
doc = asyncio.run(self.wait())
async def wait(self):
doc = await Fire2("test1"
浏览 47提问于2021-10-24得票数 0
1回答
如何实现低级异步IO函数
、、、、
Python可以在等待asyncio.sleep和aiohttp函数时切换上下文。python最终是如何知道上下文何时需要切换的？如果我想实现我自己的IO函数，我们需要调用哪些API？
在基于的基础上，我们可以使用select api让上下文在使用产率进行编程时切换。在具有异步和等待的python 3中，它仍然是唯一的方法吗？
浏览 0提问于2018-12-28得票数 1
1回答
我在试着做一个球从窗户边缘反弹的游戏。我的问题是它是超级滞后。我不知道为什么。我正在使用python3.10和玩偶游戏。无论谁找到答案，都非常感谢你。下面是我游戏的源代码。如果你修复了它，请把源代码留给固定的游戏，因为我对python是新手，并且很可能会把它放在我自己身上。LOL
import pygame
init()
S0 = 640
S1 = 480
screen = display.set_mode((S0, S1))
display.set_caption("Zero-Player-Game")
clock = pygame.time.Clock()
x =
浏览 4提问于2022-01-23得票数 1
回答已采纳
1回答
from threading import Thread, Event
import time
def countdown(n, start_evt):
start_evt.wait()
print('start counting')
while n > 0:
print('T-minus', n)
n -= 1
time.sleep(1)
if n == 96:
start_evt.clear()
start_evt = Event()
p
浏览 2提问于2017-06-19得票数 0
回答已采纳
1回答
我在Fedora 26工作站上使用Python 3.6.2。
下面是一些剪贴簿代码，它演示了我的问题：
编辑:将Sam Hartman的建议添加到代码中。
import asyncio, json
from autobahn.asyncio.websocket import WebSocketClientProtocol, WebSocketClientFactory
class MyClientProtocol(WebSocketClientProtocol):
def onConnect(self, response):
print(response.peer)
浏览 2提问于2017-11-04得票数 2
我试图运行，我在这个库node run-tests gateio --python-async的根目录下通过命令行运行它们
下面的代码导致了一个弃用警告，因为我使用的是依赖于的东西( python3.10 )，并且看起来get_event_loop被python3.10弃用了。
if __name__ == '__main__':
asyncio.get_event_loop().run_until_complete(main())
弃用警告
[100%] Testing gateio WARN (testExchange @ run-tests.js:172)
浏览 2提问于2021-11-12得票数 4
我在VB.net中运行Python时遇到了问题，因为.net程序会增加CPU的使用率。本质上，我在VB.net程序中执行Python，重定向标准输出，以便.net捕捉到Python脚本打印的内容。
Dim python_handler As New PythonHandler
python_handler.Execute("python.exe", "my_script.py")
' Wait for python_handler to get back d
浏览 2提问于2014-08-07得票数 1
回答已采纳
此代码失败：
import asyncio
from motor import motor_asyncio
_client = motor_asyncio.AsyncIOMotorClient()
_db = _client.db
users = _db.users
async def main():
await users.create_index(
'login',
unique=True
)
if __name__ == '__main__':
#loop = asyncio.get_e
浏览 1提问于2019-03-29得票数 1
回答已采纳
我正在一遍又一遍地阅读卢西亚诺·拉马略的“流利的Python”，但我无法理解异步。睡眠在异步中的行为。
书中有一个部分说：
除非您想阻止主线程，否则永远不要在异步协同中使用time.sleep，因此冻结事件循环，可能也冻结整个应用程序。(...)它应该从asyncio.sleep(延迟)中屈服。
在另一部分：
Python标准库中的每个阻塞I/O函数都释放GIL (.)time.sleep()函数还释放GIL。
由于time.sleep()可以在其他线程上释放GIL代码，但会阻塞当前线程。由于异步是单线程的，我理解time.sleep阻塞异步循环。
但是，asyncio.sle
浏览 8提问于2020-06-21得票数 7
回答已采纳
你好，我有一些命令，它平均运行30分钟，当我点击由GTK3创建的按钮时，python开始执行命令，但我的所有应用程序都冻结了。我的按钮点击的python代码是：
def on_next2_clicked(self,button):
cmd = "My Command"
proc = subprocess.Popen(cmd,shell=True, stdout=subprocess.PIPE)
while True:
line = proc.stdout.read(2)
if not line:
浏览 0提问于2012-06-26得票数 2
回答已采纳
这段代码是为一个不和谐的机器人编写的，它通过一个非异步函数发送消息，我得到了错误。我从错误中了解到没有事件循环，所以解决方案可能是创建一个事件循环。我不知道。或者也许get_event_loop()是不必要的。
Exception in thread Thread-1:
Traceback (most recent call last):
File "C:\Users\LENOVO\AppData\Local\Programs\Python\Python38\lib\threading.py", line 932, in _bootstrap_inner
self.
浏览 14提问于2022-10-07得票数 -2
回答已采纳
我有一个python脚本，它通过串行接口与设备通信。有一个要执行的函数my_fn()，它向串行接口发送一些命令，并等待设备触发recieved_fn()。如果在5秒内没有触发recieved_fn()，则再次执行my_fn()。
如何监控5秒内是否执行了recieved_fn()？
我在windows10上运行python 2.7。
谢谢
浏览 0提问于2018-06-26得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
