2回答
鉴于Python的背景，我一直试图学习JS并发模型。
在Python中运行以下代码：
async def myFunction():
print("abc")
myFunction()
什么都不会打印出来。在JavaScript中运行以下代码：
async function myFunction() {
console.log("abc")
}
myFunction()
将打印"abc"。在这两种情况下，我都没有await myFunction，但是评估是不同的。
我理解为什么Python程序什么也不打印。myFunction
浏览 4提问于2021-01-06得票数 4
回答已采纳
1回答
我有一个函数来呈现一个API页面：
@app.route('/api', methods=['GET', 'POST'])
async def index():
response = {}
if request.method == 'GET' and request.args.get('sku'):
u = "https://....."
r = async_store_check(u)
response['status
浏览 6提问于2021-12-28得票数 -2
回答已采纳
函数，我正在尝试从我的烧瓶-socketio服务器调用函数。
from flask_socketio import emit
import asyncio
async def myfunc():
for i in range(10):
j = 1*3
await emit('update', {'j':j})
在我的服务器功能中，我正在运行
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
task = asyncio.gather(myfun
浏览 1提问于2019-07-03得票数 14
2回答
通常，为了编写兼容python2/3的代码，您遵循两种解释器都可以理解的特定样式，例如：。
但是，由于异步引入了诸如async def和await function()这样的语法，如果在Python2下运行，这将导致解析错误。
如何编写一个仍然可以提供异步接口的与python 2和python 3兼容的库？如果没有简单的方法可以做到这一点，那么是否可以在库中创建一个只能在python 3.5+中导入的异步子模块？
浏览 0提问于2019-01-03得票数 2
我想从一个删减员那里得到模因。问题是，当我尝试使用subreddit('memes')方法获取模因时，该方法返回一个不可迭代的‘ListingGenerator’对象。
我想知道是否有任何方法将其转换为一个可迭代对象或任何其他方法来使用ASYNCPRAW从reddit获取模因。
以下是功能：
async def meme(self, ctx):
subreddit = await reddit.subreddit('memes')
print(type(subreddit))
all_subs = []
print(su
浏览 1提问于2021-02-11得票数 0
回答已采纳
1回答
我让我的机器人不和谐，我想这样做，当用户点击一个特定的声音频道，一个新的声音通道为他，这将被删除的退出。以下是代码：
import discord
from discord.ext import commands
from discord.utils import get
import asyncio
TOKEN = 'xxxx'
bot = commands.Bot(command_prefix='!')
@bot.event
async def on_voice_state_update(member, before, after):
if
浏览 2提问于2020-11-07得票数 0
回答已采纳
我要做的是，假设你有几个工作流需要执行。这些工作流具有任务，并且任务的目标是不同的主机。要做到这一点，最快的方法是在进程中运行每个工作流，并并行运行它们。
我正在尝试运行python multiprocessing来执行一个远程函数，该函数是我在celery的帮助下调用的。如果我只运行一个进程，我的程序运行正常。但是当我运行多个进程时，我得到下面的错误。据我所知，问题是在同一渠道上的并发发布。通道不应该在线程/等之间共享。
我怎么做芹菜才能解决这个问题呢？是应该用'celeryd‘命令启动的参数，还是需要在我的python程序中启动？
Process Process-1:
Tr
浏览 3提问于2014-04-25得票数 1
当将SQLAlchemy的literal与date对象一起使用时，它会引发异常。
Demo
# Versions used:
# databases 0.4.1
# asyncpg 0.21.0
# SQLAlchemy 1.3.20
import asyncio
from datetime import date
from databases import Database
from sqlalchemy import select, literal
database = Database('postgresql://user:password@localhost/dbname&
浏览 2提问于2020-11-30得票数 1
我正在使用python管理客户端库创建蔚蓝资源，例如azure.mgmt.eventhub.aio.EventHubManagementClient。
观测：
当调用管理服务API时，对应的azure同步库(例如azure.mgmt.eventhub.EventHubManagementClient )打印http日志，但是异步库在使用异步方法和在异步方法中使用python记录器时也不会打印类似的日志，即使这些日志也不打印.。
示例代码
logger = logging.getLogger(__name__)
logger.setLevel(logging.INFO)
浏览 4提问于2021-05-22得票数 0
首先，我要声明，我知道此错误消息已多次发布。但我似乎不明白这些职位是如何适用于我的。所以我想试试运气：
我有Dataframe "df“，我正在尝试对该dataframe的子集执行并行处理：
for i in range(1, 2):
pool = ThreadPool(processes=4)
async_result = pool.apply_async(helper.Helper.transform(df.copy(), i))
lst.append(async_result)
results = []
for item in lst:
curr
浏览 1提问于2020-05-10得票数 0
回答已采纳
我以前做过Lambda函数，但没有用Python。我知道Javascript支持异步的处理程序函数，但是如果我在Python中尝试它，我会得到一个错误。
下面是我要测试的代码：
async def handler(event, context):
print(str(event))
return {
'message' : 'OK'
}
这就是我遇到的错误：
An error occurred during JSON serialization of response: <coroutine object hand
浏览 3提问于2020-02-28得票数 20
回答已采纳
Python可用于生成shell并与其通信：
p = subprocess.Popen(['cmd'], shell=True, stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.PIPE) # use 'bash' if Linux.
使用此设置，可以发送诸如“回显foo”或“cd”命令之类的命令。但是，当我们试图在cmd行中使用程序时，会出现问题。例如，在一个普通的shell中，您可以输入python，输入" Python "，运行Python代码(和报告打印等)
浏览 5提问于2022-12-03得票数 2
3回答
我使用子进程exec (我认为它基于文档是异步的)在我的Node.js服务器上运行一个Python。
然而，当我在web上搜索和Stack溢出时，我看到了许多在async中为子进程使用承诺和await/await的实例。
这让我很好奇，如果子进程(exec、execFile、spawn、fork)已经是异步函数，为什么要在它们上使用承诺或async/await。
浏览 0提问于2019-11-27得票数 2
回答已采纳
代码：(错误在行results.html.render())渲染工作时，我以前没有使用AsyncHTMLSession，但使用了HTMLSession。
from requests_html import AsyncHTMLSession
link="https://www.daraz.com.np/catalog/?q={}"
asession = AsyncHTMLSession()
async def get_daraz():
r = await asession.get(link.format("mouse"))
return r
re
浏览 72提问于2020-05-13得票数 1
1回答
我最近写了一个不和谐的机器人，它播放本地的mp3文件。我用来播放文件的函数如下所示。
conn.play(discord.FFmpegPCMAudio("path/to/file"))
while conn.is_playing():
time.sleep(0.1)
await conn.disconnect()
现在我正在考虑为多台服务器设置机器人。我的问题是，如果我想同时在两个不同的服务器上播放两种不同的声音，机器人目前只能按顺序播放，而不能同时播放。我考虑为每个服务器设置多个python实例，但对于N服务器、N个python实例来说，管理起来似乎有点困难。我可以为
浏览 2提问于2021-02-03得票数 0
回答已采纳
以下异步生成器代码直接从PEP525中删除：
async def gen():
await asyncio.sleep(0.1)
v = yield 42
print(v)
await asyncio.sleep(0.2)
然而，当我打电话(用python3.6)时：
print(asyncio.iscoroutinefunction(gen), asyncio.iscoroutine(gen))
我得到：
False, False
为什么异步生成器不能识别为协同函数？
还有其他方法可以将其识别为协同函数吗？
浏览 3提问于2019-12-15得票数 4
回答已采纳
我想要的是当我运行xyz.py时，它应该在bot.py运行的终端中打印"works“
因此，我想在不和谐的bot python文件中调用一个函数，该文件已经从另一个python文件中运行:在bot.py中：
async def call_1():
print("works")
在xyz.py中：
from bot import call_1
call_1()
现在bot.py正在运行，然后我运行xyz.py。
所发生的是xyz.py将再次运行机器人
浏览 4提问于2022-08-24得票数 0
我正在探索异步http请求的aiohttp。
aiohttp 上的客户端快速启动建议将此代码作为一个最小的示例：
import aiohttp
async with aiohttp.ClientSession() as session:
async with session.get('http://httpbin.org/get') as resp:
print(resp.status)
print(await resp.text())
对于我来说，python 3.6.5的结果是
使用aiohttp.ClientSession()作为
浏览 0提问于2018-11-01得票数 0
回答已采纳
大家好，我是python的新手，我正在尝试使用Detrous制作的Dark Sky python API。当我运行演示代码时，出现了一个错误：
forecast = await darksky.get_forecast(
^
SyntaxError: 'await' outside function
此错误由以下原因引起：
forecast = await darksky.get_forecast(
latitude, longitude,
extend=False, # default `False`
lang=langua
浏览 0提问于2019-10-19得票数 7
我想连接websockets，但是在启动时会出错。
uvicorn app:app --reload --ws websockets
需求
OS：LinuxUbuntu20.04 LTS
Python 3.8.6
Browser：Chrome 88.0.4324.182
fastapi==0.63.0
python-engineio==4.0.0
python-socketio==5.0.4
starlette==0.13.6
uvicorn==0.13.3
websockets==8.1
app.py
from typing import Optional
import socketio
浏览 6提问于2021-03-02得票数 4
1回答
我对python 3.8.5和3.7有问题
给定方法：
import asyncio
import functools
_executor = ThreadPoolExecutor()
async def request_async(*args, **kwargs) -> requests.Response:
loop = asyncio.get_event_loop()
response = await loop.run_in_executor(_executor, functools.partial(requests.request, *args, **kwar
浏览 0提问于2021-07-29得票数 0
为什么下面的异步url open函数比顺序函数慢？在任何情况下，async_func都比sequential_exec慢。为什么跟随异步函数花了这么长的时间？
virtualbox上的Ubuntu18.10上的Python3.7 (主机: Windows10)
import urllib.request
import asyncio
import time
urls = [
"https://www.google.co.jp",
"https://github.com",
"https://example
浏览 0提问于2018-12-13得票数 0
我试图在Python3.x中的Flask应用程序中获得一个异步运行的函数。我正在使用asyncio库，并将async放在函数声明之外，但我得到了一个错误，即：
Traceback (most recent call last):
File "/usr/local/lib/python3.6/site-packages/flask/app.py", line 1997, in __call__
return self.wsgi_app(environ, start_response)
File "/usr/local/lib/python3.6/site-
浏览 0提问于2018-06-29得票数 3
回答已采纳
1回答
Python异步，期货和收益
、、、、
考虑以下程序(运行在CPython 3.4.0b1上)：
import math
import asyncio
from asyncio import coroutine
@coroutine
def fast_sqrt(x):
future = asyncio.Future()
if x >= 0:
future.set_result(math.sqrt(x))
else:
future.set_exception(Exception("negative number"))
return future
def slo
浏览 3提问于2013-12-22得票数 12
回答已采纳
2回答
我正在尝试制作一个电报机器人，它解析GTFS数据并返回用户地铁列车的状态。我正在使用python-电报- bot库，到目前为止，我创建的机器人都是我想要的工作。
然而，我写了一些非常丰富的功能，处理熊猫的数据，以获得火车时间表。我只是意识到，如果您有一个用户请求，这些函数就能正常工作，否则，由于它们不是异步的，所以它们被序列化并阻止后续的请求(如果我错了，请纠正我)。
我读过异步可能很适合它，但我无法使它工作。在实践中，我能做些什么来异步这些函数？
浏览 10提问于2022-07-07得票数 0
回答已采纳
我正试着使用Telethon，但发现它太慢了 因此，我尝试按照this post中的建议使用this gist 我有以下错误。有谁能帮帮我吗？ 下面是我的代码： from telethon.sync import TelegramClient
from FastTelethon import download_file
import os
import asyncio
async def getAllMediaFromchannel():
os.chdir("/home/gtxtreme/Documents/McHumour")
api_hash = &#
浏览 348提问于2020-08-04得票数 0
我使用的是由两个套接字(DUT)组成的TestStand。每个DUT连接一个串行接口来发送/接收数据。现在我有了一个pyhton脚本，它打开串行接口并交换数据。python脚本使用Com-端口号作为输入参数。
到目前为止，python脚本适用于DUT 1或DUT2，没有任何问题。现在，我想在TestStand中实现和使用这个python。
问题：
是否可以使用TestStand并行执行这个python脚本？
如果是，我需要如何设置TestStand才能并行运行测试？
在使用批处理模型时，我确实可以访问两个DUT2，但数据不是并行的，而是按顺序进行的(首先是DUT1，然后是DUT
浏览 3提问于2022-07-15得票数 0
1回答
我在想，有没有理由声明一段没有函数的代码作为async def (协程)而不是def ( await )？Python明确地允许这样做。 def i_am_sync():
return 42
async def i_am_async():
return 42 我知道协程版本可以安排在事件循环上，但我无法想象这会有什么实际应用，因为您可以直接调用同步代码吗？
浏览 22提问于2020-01-04得票数 2
回答已采纳
1回答
我一直在使用项目与cosmosdb-gremlin合作。
当我将它作为python函数在windows上运行时，项目就会很好地工作。
现在，我正在尝试将这段代码转换成天蓝色函数。
我能够转换和运行，面临两个问题(tornado+python3.8兼容性问题) (nest_asyncio)。现在我已经解决了这些错误，但我仍在跟踪(随附截图)。
当我试图关闭连接时，会出现此错误。
client.close()。
因此，为了避免完全的流失败，我只是将其封装在try/catch中。因此，现在流程正在进行，在功能上，我没有看到任何副作用。
但是后来我注意到了，线程数随着每次运行而不断增加。我不确定这是否
浏览 9提问于2021-02-22得票数 0
回答已采纳
2回答
在OS上，我的代码工作正常。在ubuntu上尝试正确的代码，我得到了一个语法错误：
ubuntu@home:server$ python3 server.py
File "server.py", line 39
async def hello(websocket, path):
^
SyntaxError: invalid syntax
我使用pip3 install asyncio安装异步
我也尝试过升级到python 3.5，但是它在其他库中会导致大量的库错误，到目前为止，我无法在ubuntu上使用python3.5，尽管它在OS上使用p
浏览 2提问于2016-08-11得票数 2
回答已采纳
2回答
Python中的异步函数或线程
、、、、
我正在用python编写一个小应用程序，使用一些http服务，但我真的不明白使用异步函数还是使用线程来使用这些服务的区别。
有人能帮我理解吗？
浏览 1提问于2019-09-14得票数 1
1回答
扭曲提供了包装本机协同(coroutines使用异步/等待)。使用ensureDeferred，我们可以包装一个协同线并得到它的等效延迟。如何包装异步生成器(在Python3.6中可用)，从而获得延迟？
试图包装异步对象将返回以下错误：
File "/home/yash/Scrapy/vnv/lib/python3.6/site-packages/Twisted-17.9.0-py3.6-linux-x86_64.egg/twisted/internet/defer.py", line 915, in ensureDeferred
raise ValueError("%
浏览 1提问于2018-03-13得票数 0
我试图理解异步模块，并花了大约一个小时使用run_coroutine_threadsafe函数，我甚至看了一下工作示例，它的工作原理与预期一样，但有几个限制。
首先，我不明白如何正确地调用主线程(任何其他线程)中的异步循环，在这个示例中，我用run_until_complete调用它，并给它一个协同线，让它忙着做某事，直到另一个线程不会给它一个协同线。我还有别的选择吗？
在现实生活中，当我必须混合异步和线程(在Python中)时，会发生什么情况？据我所知，异步应该代替Python中的线程(因为GIL不是IO操作)，如果我错了，请不要生气，并分享您的建议。
Python版本为3.7/3.8
im
浏览 2提问于2020-02-07得票数 12
回答已采纳
我正在尝试使用python包异步获取一个URL列表，类似于使用Python3.6.5和requests_html 0.10.0的。
我的理解是，AsyncHTMLSession.run()应该与asyncio.gather()一样工作:您给它一堆可等待的东西，并且它们都运行。这不对吗？
下面是我正在尝试的代码，我希望它能得到页面并存储响应：
from requests_html import AsyncHTMLSession
async def get_link(url):
r = await asession.get(url)
return r
asession = As
浏览 1提问于2019-11-13得票数 2
回答已采纳
我在我的烧瓶项目上有这样的配置：
在requrement.txt中：
flask_socketio
eventlet
在我的app.py：
from flask_socketio import SocketIO
socketio = SocketIO(app, async_mode="eventlet")
@socketio.on('register')
async def register(data):
await my_asyncfunction(data['machine_id'])
和my_asyncfunction：
as
浏览 5提问于2020-12-19得票数 0
我使用的是Python3.5，根据的说法，它应该可以访问async with语法，但是当我尝试使用它时，我得到了一个SyntaxError。我做错了什么？
In [14]: sys.version
Out[14]: '3.5.2 (default, Oct 11 2016, 04:59:56) \n[GCC 4.2.1 Compatible Apple LLVM 8.0.0 (clang-800.0.38)]'
In [15]: async with aiohttp.ClientSession() as session:
File "<ipython-inp
浏览 0提问于2017-02-17得票数 20
回答已采纳
我用姜戈芹菜和芹菜拍打来执行定期任务。我每隔一分钟运行一次任务，通过SNMP获取一些数据。
我的函数使用异步，如下所示。我在代码中放置了一个检查，以检查循环是否关闭，并创建一个新的循环。
但是似乎正在发生的是每几个任务，我得到了一个失败，在Django-任务-结果db中我有下面的回溯。似乎每隔3分钟就会有一次失败，但每分钟都有成功，而不是失败。
错误：
Traceback (most recent call last):
File "/usr/local/lib/python3.6/site-packages/celery/app/trace.py", line 374,
浏览 0提问于2018-05-15得票数 0
回答已采纳
2回答
我想在Python中使用Rust异步方法。我正在尝试使用PyO3或rust-cpython。 例如，对于sync Rust函数，我可以使用， #[pyfunction]
fn myfunc(a: String) -> PyResult<String> {
let mut contents = String::new();
contents = a.to_string() + " appended";
Ok((contents))
}
#[pymodule]
fn MyModule(py: Python, m: &PyModule)
浏览 21提问于2020-06-28得票数 5
回答已采纳
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
3回答
您好，我正在尝试使用从函数中获得的值，并希望在函数之外使用它。我有一个python脚本，它试图使用node调用，并希望在node函数之外使用从python脚本返回的值。
下面是我想要做的，我希望在函数外部使用aa值：
PythonShell.run(PythonfilePath, options, function (err, results) {
if (err)
throw err;
let aa = parseInt(results)
});
console.log(aa)
我想使用aa中的值存储
浏览 2提问于2018-06-28得票数 1
1回答
我有一个Google Cloud Function (python)，它迭代数据集并在满足特定条件时触发其他Google Cloud函数(在迭代中)。
有没有一种方法可以在不等待响应的情况下向云函数发送HTTP POST请求？等待响应会使我的迭代器函数变慢。
我一直在研究requests模块中的timeout参数，但它似乎不起作用。
requests.post(function_trigger,headers=headers,data=json.dumps(payload), timeout=0.5)
有什么想法吗？
浏览 5提问于2019-08-15得票数 1
我的代码
const model = tf.loadLayersModel('../model/model.json');
// python
function pyFun(arrayOne){
var arrayReturn = new Array(5000);
for (i=0;i<5000;i++){
arrayReturn[i]=0;
}
var arrayTwo = arrayOne.map(myFunction);
function myFuncti
浏览 0提问于2020-10-05得票数 0
1回答
我想给我的机器人做个音乐齿轮。我目前正在命令机器人加入并离开一个语音频道。但是，每次我尝试启动这两个命令时，都会发生相同的错误。
Ignoring exception in on_message
Traceback (most recent call last):
File "C:\Users\Daniel\AppData\Local\Programs\Python\Python38\lib\site-packages\discord\ext\commands\core.py", line 663, in _parse_arguments
next(iterator
浏览 2提问于2020-04-28得票数 1
回答已采纳
我在我的django项目中使用mongoDB的马达驱动程序，我在将我的数据(来自数据库的游标)转换成列表时遇到了问题，下面是我的代码：
documents = db.factor.aggregate([{"$limit": 3},
{"$lookup": {"from": "subfactor", "localField": "_id", "foreignField": "factor_id", "as": "subfactor
浏览 57提问于2021-02-16得票数 2
回答已采纳
2回答
我已经使用了python异步框架，比如Twisted和Tor旋风。另外，我知道python已经通过异步模块实现了异步调用。我认为(线程、多处理)和异步调用是不同的概念。但不久前，我看了几个与线程和多处理相关的视频，似乎所有的异步人员都建立在它们之上。是真的吗？
浏览 4提问于2016-01-07得票数 5
回答已采纳
我的任务是构建一个使用PyScript进行线性回归预测的项目，因此我使用了scikit--在Javascript和面板的帮助下进行学习。这是我的完整代码：
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<meta name="viewport
浏览 3提问于2022-06-05得票数 1
回答已采纳
3回答
最近，我试图在postgres db中使用编码/数据库包。我做得都是对的。但是当我使用uvicorn运行它时，我看到它显示了psycopg2没有安装。我不想使用psycopg2。因此，我重新声明了所有内容，运行了databases[postgresql]，而不是只运行databases。我还安装了asyncpg。但我还是看到了同样的错误。I也在虚拟环境中做任何事情。我的代码附在下面：
import databases, sqlalchemy, asyncpg
from fastapi import FastAPI
#POSTGRES DATABASE
DATABASE_URL = "
浏览 6提问于2020-12-04得票数 1
回答已采纳
我刚接触过节点js，
我从节点调用python脚本，并希望等到python脚本结束。最简单的方法是什么？我的代码：
PythonShell.run('public/python/dag.py', null, function (err,result) {
if (err) throw err;
console.log(result)
})
console.log("amit")
我的产出：
"amit"
["hey python&
浏览 2提问于2021-12-05得票数 1
我想在构造函数中找到一个文件夹。所以，我需要一个非异步的方法。
public static Windows.Storage.StorageFolder getStorageImagesDir()
{
Windows.Storage.StorageFolder folder = Windows.Storage.ApplicationData.Current.LocalFolder.CreateFolderAsync("images", CreationCollisionOption.OpenIfExists).GetResults();
浏览 3提问于2012-11-28得票数 1
回答已采纳
1回答
我尝试从用户那里获取一张图像作为输入，并使用python对其进行处理，然后在node js中显示处理结果。为此，用户首先上传图像，然后我将其保存在uploads文件夹中。然后，python脚本获取该图像并对其进行处理，然后将其保存在相同的位置。最后，我显示新图像。我尝试过使用异步语句和promise，但它们似乎不起作用。 app.post("/image", function(req, res){
upload(req, res, (err)=> {
if(err){
res.render('upload', {
浏览 23提问于2020-07-03得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
