1回答
我刚刚开始了MS70-463仓库的实现，在视频课程上导师正在指导SQL Server 2012评估版，但我已经有了一个SQLServer2012Express。
有谁能告诉我，这是否足以满足我想要的课程？是否有我不能在70-463课程中执行的功能？
浏览 0提问于2016-01-02得票数 6
不久前，我从David Beazley的协程程序上读到了，我想知道是否有实际的基于Python的软件使用它们？
为什么协程看起来像是Python中最未使用的功能？
浏览 0提问于2011-04-23得票数 8
1回答
这其实是我两个月来一直在考虑的面试问题，却找不到合适的建筑。
问题
我们想建立一个小的分析系统来检测订单上的欺诈行为。
系统有以下要求
memory10M 不允许使用来自市场的任何技术(MySql，Redis，Hadoop，S3等)，需要扩展，因为数据量增长了<code>H 111</code>只是一堆机器，有磁盘和相当数量的写/日<代码>H 216</代码><代码>F 217</代码>
系统需要提供以下API
/insertOrder(order): Order
将订单添加到存储区。该订单可被视为具有1-10 and 的
浏览 6提问于2021-09-23得票数 0
回答已采纳
1回答
我通过lua脚本从浏览器执行python脚本：
os.execute('python scriptname.py --arg1 Test --arg2 Test2')
我再次这样做(例如，通过刷新页面，发送表单)
os.execute('python scriptname.py --arg1 Test3 --arg2 Test4')
我希望第二个脚本只被执行时，第一个脚本完成到最后。我希望脚本被添加到队列中，并从最旧的脚本到最新的脚本执行。我该怎么做呢？
浏览 2提问于2018-07-08得票数 0
1回答
我对Python和ECMAScript中的生成器的理解是，它们比普通生成器更强大。例如，它们都允许通过next()将值传递回生成器，并且都允许从另一个生成器(Python中的yield from和ES6中的yield * )生成，这是生成器中不需要的两件事。
那么，考虑到这种扩展的功能，在Python和ES6中实现的生成器是否与协程相同？有什么不同吗？
浏览 0提问于2015-08-08得票数 1
2回答
我有一个关于协程实现的问题。我首先在Lua和stackless-python上看到了coroutine。我可以理解它的概念，以及如何使用yield关键字，但我不知道它是如何实现的。
我能得到一些关于它们的解释吗？
浏览 2提问于2010-08-09得票数 4
回答已采纳
从文档中我有这个例子，我已经测试过了，并且工作正常。
from requests_html import AsyncHTMLSession
asession = AsyncHTMLSession()
async def get_pythonorg():
r = await asession.get('https://python.org/')
async def get_reddit():
r = await asession.get('https://reddit.com/')
async def get_google():
r
浏览 5提问于2021-05-23得票数 1
我正在使用Python和Tornado来构建带有jquery UI滑块元素的基本应用程序。我的目标是，当用户与滑块交互时，它将被发送一个值给python函数，结果将显示在python控制台中。我的custom.js是：
$(function() {
$("#slider-range-max").slider({
min : 0,
max : 100,
slide : function(event, ui) {
$("#amount").val(ui.value);
ajax({
浏览 2提问于2016-05-16得票数 4
我正在做一个十六进制game.But游戏，问题是产生的对象是重叠的，因为我是随机的，我想删除重叠的对象，并按照图片中的方式对它们进行排序，但我做不到。我正在使用unity engine.You可以在这方面提供帮助？ void Update()
{
StartCoroutine(Create());
}
IEnumerator Create()
{
yield return new WaitForSeconds(start_standby);
while (true)
{
for (int i = 0; i < 10; i
浏览 8提问于2019-03-30得票数 0
我正在尝试为我的异步循环设置一个标志。我试着使用asyncio.Event，但得到了一个RuntimeError，下面是我的代码： import sys
import asyncio
import logging
root = logging.getLogger()
root.setLevel(logging.DEBUG)
ch = logging.StreamHandler(sys.stdout)
ch.setFormatter(
logging.Formatter('%(asctime)s - %(name)s - %(levelname)s %(message)s&
浏览 54提问于2020-12-18得票数 0
我已经创建了一个hangman命令，但在调用该命令时出现错误，如第二段代码所示。有没有人知道这个错误指的是什么，或者我当前代码中的错误？
@bot.command()
async def hangman(self, ctx):
"""Play hangman!"""
game = Hangman(ctx, self.bot)
await game.play()
Ignoring exception in command play:
Traceback (most recent cal
浏览 1提问于2021-01-26得票数 2
我目前正在尝试用Python学习asyncio。我知道await关键字告诉循环它可以切换协程。但是，我应该在什么时候实际使用它呢？为什么不把它放在第一位呢？
另外，为什么await在'response.text()‘之前，为什么不在session.get(url)之前？
async def print_preview(url):
# connect to the server
async with aiohttp.ClientSession() as session:
# create get request
async with ses
浏览 0提问于2020-05-15得票数 0
2回答
我已经看到很多关于python中的协程的演讲和文章。它们被认为是“微线程”，我听说它们可以提高性能。
协程如何提高性能？到目前为止，我看到的是它们是单线程的，并且是按顺序执行的。我同意从设计的角度来看，它们非常优雅，特别是在生产者/消费者类型的应用程序中。
我想我没有抓住要点。有人能帮我解释一下吗？
浏览 0提问于2011-07-05得票数 16
回答已采纳
1回答
我尝试使用Python进行异步编程，遇到了一个有趣的应用程序，我需要在大约100台机器上收集大约10个文件的文件大小，以查看哪些机器没有适当地清除它们的日志文件。
我的同步方法是：
File_info = namedtuple("File_info", "machineinfo size")
machines = utils.list_machines() # the computers being queried
# each machine object has attributes like "name", "IP",
浏览 1提问于2017-04-14得票数 0
4回答
对于对其他语言(Python/JavaScript)有一定异步经验的人来说，当谈论异步/等待时，总是会假设在某个地方有一个事件循环。但是对于C++，我已经浏览了文档，没有找到任何讨论事件循环的地方。为什么会这样呢？
对于Node，它只有一个默认的事件循环。对于Python，如果需要，您可以创建多个。但是对于C++，这个事件循环是不是和Node一样呢？或者出于某种原因，我们根本不需要它吗？
浏览 7提问于2021-02-20得票数 19
1回答
如何从异步函数返回值
、、、、
我有一个异步函数，我试图从其中获取返回变量，但由于某种原因，我无法让它工作，我尝试了几个与googling不同的方法，但它们都返回类似的错误。 我有这个函数： @bot.command()
async def start(ctx):
"""starts the server"""
try:
status = server.status()
await ctx.channel.send("The server is already online!")
except:
浏览 30提问于2020-04-16得票数 2
我有一个使用asyncio和await模块的python程序。这是我取自的一个示例程序。
import asyncio
import os
import urllib.request
import await
@asyncio.coroutine
def download_coroutine(url):
"""
A coroutine to download the specified url
"""
request = urllib.request.urlopen(url)
filename = os.
浏览 3提问于2016-08-04得票数 2
我知道在python37中我们有一个新的接口asyncio.get_running_loop()，它很容易使用，让我们在调用协程时不需要显式地传递eventloop。 我想知道是否有什么方法可以让我们在python36中获得同样的效果？ # which allows us coding conveniently with this api:
import asyncio
async def test():
print("hello world !")
async def main():
loop = asyncio.get_running_loop()
浏览 33提问于2019-06-25得票数 4
回答已采纳
1回答
我正在对我的python代码做一些分析。我正在使用异步api进行rpc调用
async def rpc_call():
return client.call(params) // makes rpc calls over tcp
async def test():
await rpc_call()
start = time.time()
loop = asyncio.get_event_loop()
tasks = []
for i in range(10000):
tasks.append(asyncio.ensure_future(test()))
pri
浏览 0提问于2018-04-22得票数 1
1回答
我想返回异步生成器的第一个元素，并处理剩余的值，而不返回像fire和forget那样的值。如何在python中提前返回协程？在将迭代器传递给asyncio.create_task之后，它不会打印剩余值。
import asyncio
import time
async def async_iter(num):
for i in range(num):
await asyncio.sleep(0.5)
yield i
async def handle_remains(it):
async for i in it:
print(
浏览 2提问于2021-09-27得票数 0
已将torando v5.1迁移到v6。但是异步协程似乎已经被移除了。对它的修复有什么建议？ 将项目从2.7迁移到3.6，同时将tornado框架从v5.1迁移到v6.0.2，因为这个[Python code for DynamoDB query is working on v3.6 but not working in python 2.7 strackoverflow线程]中建议的错误。 安装v6 tornado后，它会中断，并出现以下错误。 Python3 xxxx.py
Traceback (most recent call last):
File "XXXX.py&#
浏览 84提问于2019-04-02得票数 1
我很难理解asyncio的整个概念。现在，我尝试将Socket模块和asyncio一起使用，使UDP聊天同时作为服务器和客户端工作。在两个asyncio协程中，我运行循环(一个用于服务器，一个用于客户端)。但是程序只能作为客户端工作。在网络上发送数据，但不接收数据。我猜对于这种情况有更好的asyncio解决方案，但在继续之前，我想了解为什么特定的代码不工作。你有什么线索吗？
# PYTHON 3.4
import asyncio
import socket
PORT = 50001
MAX_BYTES = 8400
LOCAL_IP = ''
REMOTE_IP = '
浏览 2提问于2016-02-21得票数 1
2回答
协程是简化并发编程的一个很好的范例。大多数情况下，并发任务很容易并行化。在语言中，使用goroutines执行并行任务是很容易的。有没有办法在Python中做同样的事情，例如使用协程来创建进程并同步它们？
浏览 5提问于2011-06-30得票数 5
回答已采纳
在Python语言中，await使用协程和使用asyncio.run()的实际区别是什么？它们似乎都在运行协程，我能看到的唯一区别是await只能在协程中使用。
浏览 12提问于2020-11-23得票数 7
回答已采纳
在Python中-使用纯a = yield协程语法，而不是像asyncio这样的库-在收到响应之前发出一个HTTP请求并做一些其他事情，这是可能的吗？类似于： >>>requests.get('http://www.json-generator.com')
# do something else here while the above request is being made 就像使用AJAX一样，人们可以发出请求，而不必等待响应？或者我可能误解了协程背后的想法？
浏览 27提问于2019-01-07得票数 4
回答已采纳
7回答
在python中，yield关键字可以在push和pull上下文中使用，我知道如何在c#中执行pull上下文，但如何实现push呢？我发布了我试图从python中用c#复制的代码：
def coroutine(func):
def start(*args,**kwargs):
cr = func(*args,**kwargs)
cr.next()
return cr
return start
@coroutine
def grep(pattern):
print "Looking for %s" % pattern
try:
w
浏览 0提问于2010-03-22得票数 10
回答已采纳
1回答
我的服务已经使用Websockets与tcp服务器通信，它还连接到另一个tcp端点。
它做两件事
1/ tcp从the服务器读取数据=>将其写入=>端点
2/ tcp从=>端点读取数据，并将其写入=>服务器。
我有以下代码来实现此目的
import websocket
import asyncio
def open_remote(reader):
print("open remote")
do_remote_read(reader)
def on_message(ws, message):
print("message re
浏览 10提问于2019-10-21得票数 0
我目前正在vim中开发一些异步python，并将作为插件安装。但是我遇到了一个文件内联的问题，因为林特在第一个(也是有效的) async定义上挂起，不会内联文件的其余部分。
@user_bp.get('/api/v1/user')
async def get_users(request): # `invalid syntax` error on 'async', linting stops here
with scoped_session() as session:
statement = User.__table__.select()
浏览 3提问于2018-01-01得票数 1
1回答
我正在试着写一个简单的网络爬虫来测试新的asyncio模块是如何工作的，但是有些地方我搞错了。我正在尝试使用单个URL启动爬虫程序。该脚本应该下载该页面，找到该页面上的任何<a>标记，并安排它们也被下载。我期望的输出是一串行，指示第一个页面已经下载，然后以随机顺序(即，当它们被下载时)随后的页面，直到所有的完成，但看起来他们实际上只是按顺序下载。一般来说，我对异步是一个全新的了解，尤其是这个模块，所以我确信我只是遗漏了一些基本的概念。
到目前为止，我的代码如下：
import asyncio
import re
import requests
import time
from bs
浏览 1提问于2015-06-22得票数 1
1回答
我真的很欣赏Stackless Python的功能，我一直在寻找一种方法来模拟它的语法，同时仍然使用标准的Python3解释器。让它看起来像是greenlet库可以提供这种功能。我稍微修改了他的代码，但我能想到的最好的临时tasklet包装器是一个在变量中包含一个greenlet的类，如下所示：
class tasklet():
def __init__(self,function=None,*variables):
global _scheduled
self.greenlet = greenlet.green
浏览 4提问于2013-07-28得票数 0
我是Python并发编程的新手。这是一个我必须处理的非常简单的例子，但它遇到了一个错误： class Parser(object):
def __init__(self):
self.parser = None
async def parse(self, text):
return text
async def call_parser(text):
parser = Parser()
parsed = await parser.parse(text)
if __name__ == "__main__":
浏览 5提问于2019-06-30得票数 1
回答已采纳
1回答
对Lua中的协程的支持是由提供的，主要是create、resume和yield。开发人员将这些协程描述为。
在Python中也可以使用协程，可以使用 (和)，也可以使用3.5版中添加的。
Python中的协程与Lua中的协程相比如何？它们也是堆叠的、一流的和不对称的吗？
为什么Python需要这么多构造(async def、async with、async for、等)对于协程，而Lua只能为它们提供三个内置函数？
浏览 57提问于2016-09-24得票数 16
1回答
我已经读过这个答案()，我想要做的是与之相反的。
我想调用一个Python异步函数，并在tokio的运行时中等待它。有可能吗？
我已经尝试了几次，但在输出中遇到错误。
这是我的python文件的样子：
import rust_package
async def h():
print("message from coroutine")
print("Hello world")
s = rust_package.Server()
s.start(h)
这是我的lib.rs的样子：
#[pyclass]
struct Server {}
#[pymet
浏览 11提问于2021-05-26得票数 1
回答已采纳
我读过一些关于协程的文章，特别是关于python的，有些东西对我来说并不是很明显。
我实现了一个生产者/消费者模型，它的基本版本如下：
#!/usr/bin/env python
class MyConsumer(object):
def __init__(self, name):
self.__name = name
def __call__(self, data):
return self.observer(data)
def observer(self, data):
print self.__name +
浏览 0提问于2011-04-15得票数 4
回答已采纳
1回答
正如中所述，我们可以使用asyncio.coroutine装饰器将函数转换为协程，如下所示：
def hello():
print('Hello World!')
async_hello = asyncio.coroutine(hello)
但是，从Python3.8开始，这个函数就被弃用了(被async def ...取代)。那么，如果没有async def ...，我们如何在3.8+中做到这一点呢
浏览 28提问于2021-03-05得票数 0
回答已采纳
我正在开发一个Python-3程序，它试图做两件事：(1)从外部websocket (非阻塞)读取数据(类型1)和(2)在常规UDP套接字(非阻塞)上接收数据(类型2)。 在很长一段时间内，websocket和UDP套接字上都没有数据。因此，我尝试使两种数据类型的读取/接收都是非阻塞的。我正在尝试使用Asyncio和Websockets来为websocket执行此操作。 不幸的是，只要websocket上没有数据(类型1)，下面的代码就会挂起。它会阻止其余的代码执行。我做错了什么？ 提前感谢大家的帮助。 import asyncio
import websockets
import sock
浏览 45提问于2019-09-15得票数 8
回答已采纳
1回答
我在英特尔-cpu mac上使用python3和jupyter笔记本电脑
我想把15列和25600行csv文件变成
60列6400行
只是做
新第0行=第0行、第1排、第2排、第3行
新的第1行=第4行、第5排、第6排、第7行
诸若此类
我能做什么?
浏览 3提问于2022-06-30得票数 0
回答已采纳
1回答
我发现了一些关于使用yield from在Python 中修饰生成器函数的非常有用的信息。例如：
def mydec(func):
def wrapper(*args, **kwargs):
print(f'Getting values from "{func.__name__}"...')
x = yield from func(*args, **kwargs)
print(f'Got value {x}')
return x
return wrapper
@my
浏览 8提问于2018-08-31得票数 3
回答已采纳
1回答
我正在尝试更好地理解aiohttp。有没有人可以检查一下为什么我的代码不打印请求的响应，而只是打印协程。 import asyncio
import aiohttp
import requests
async def get_event_1(session):
url = "https://stackoverflow.com/"
headers = {
'content-Type': 'application/json'
}
response = await session.request(&#
浏览 186提问于2020-08-14得票数 1
回答已采纳
1回答
我正在运行一个python程序来监听azure iot集线器。该函数将返回一个协程对象，而不是json。我看到，如果我们使用异步函数并将其作为正常函数调用，则会发生这种情况，但我创建了一个循环来获取事件，然后使用run_until_complete函数。这里我漏掉了什么？
async def main():
try:
client = IoTHubModuleClient.create_from_connection_string(connection_string)
print(client)
client.connect()
浏览 8提问于2021-03-24得票数 1
我们有以下python代码： ListenPort = 'http://180.13.1.245:3011'
sio = socketio.Client()
sio = socketio.AsyncClient()
@sio.event
def connect():
print("Connected!")
@sio.event
def connect_error():
print("Connection failed!")
@sio.event
def disconnect():
print("Di
浏览 28提问于2020-08-22得票数 0
回答已采纳
根据官方文档，我正在使用tornado的异步功能，如下所示：
@tornado.web.asynchronous
@tornado.gen.coroutine
def get(self):
...
response = yield calendar.events()
self.write(json.dumps(response, default=json_util.default))
self.finish()
calendar.events()是数据库操作，死机了，出现以下断言错误，有什么问题吗？
HTTPServerRequest(protocol='
浏览 0提问于2015-08-16得票数 0
我正在为python >3.5编写代码。我使用的是Websockets 6.0库，这里是：，我一直叫它们asyncio Websockets，因为它们是基于异步的。在我的搜索中，有很多“丢失的连接”，但我正在研究如何取消当前的ws.recv()。对.start()的调用将创建一个帮助器线程来启动异步事件循环。然后接收函数启动并调用连接函数，websocket ws被实例化。然后，接收函数工作秋季消息。当我准备停止时，会调用一个.stop()。我期望stop函数能停止等待的ws.recv()。然后，在keep_running标志设置为false并运行ws.close()的情况下，我期望ws
浏览 805提问于2018-06-30得票数 1
from quart import Quart, request, render_template, jsonify
import json
import os, sys
import pandas as pd
import requests
import asyncio
from pylon.model.db_models import RawFiles
from pylon.orm import db
app = Quart(__name__)
@app.route('/upload', methods=['POST'])
async def han
浏览 35提问于2020-09-05得票数 3
在下面的页面()中，我在如何使用AppEngine管道的示例中看到了以下代码：
class AddOne(pipeline.Pipeline):
def run(self, number):
return number + 1
class AddTwoAndLog(pipeline.Pipeline):
def run(self, number):
result = yield AddOne(number)
final_result = yield AddOne(result)
yield LogMessage('The value is:
浏览 0提问于2011-10-16得票数 1
回答已采纳
我花了一段时间来尝试安排异步功能。我的理解是，AsyncIOScheduler会让我做到这一点，但在这个特定的代码块中，我没有得到任何乐趣。 简单地运行一个基本示例是没有问题的： from datetime import datetime
import asyncio
from apscheduler.schedulers.asyncio import AsyncIOScheduler
async def tick():
print(f"Tick! The async time is {datetime.now()}")
if __name__ == '
浏览 471提问于2021-07-02得票数 0
回答已采纳
我尝试在Python语言中异步运行for循环，就像在Javascript中使用map方法和promise.all所做的那样。我到处寻找如何做到这一点，但下面的代码仍然在同步运行(一个接一个地做，而不是像promise.all允许的那样，让循环在前一个循环结束时进行其他迭代)。任何帮助都将不胜感激。
from jwt import scopes
from googleapiclient.discovery import build
from google.oauth2 import servic
浏览 1提问于2019-08-01得票数 0
1回答
我正在尝试使用图形工具在python中创建一个交互式有限状态自动机，但是我不能让边标签工作。
以下是python文件：
from graph_tool.all import *
g = Graph()
edge_labels = g.new_edge_property("string")
a = g.add_vertex()
b = g.add_vertex()
e = g.add_edge(a, b)
edge_labels[e] = 'a'
props = {'text': edge_labels}
graph_draw(
g,
浏览 2提问于2017-10-12得票数 1
目前，我正在尝试在FastAPI python中开发两个API，一个异步提交作业，另一个Get API根据请求回复您作业完成的当前状态。请帮助我实现这一点或任何其他标准的方式，通过它我可以利用在object中创建的AsyncResult对象。请参考下面的代码。
def worker(x):
#perform computation
# POST API which starts job
@app.post("/jobs/", status_code=HTTP_201_CREATED)
async def create_job():
浏览 3提问于2020-05-16得票数 0
1回答
龙卷风不能正确产生期货
、、、、
我需要在tornado请求处理程序中异步进行几个http调用。 尝试返回期货没有很好的文档记录，而且在龙卷风处理程序级别的聚集asyncio.gather上几乎不可能做到。 我已经尝试过aiohttp，它本身工作得很好，但是当把它放在一个tornado处理程序中时，它抛出的循环已经在使用了。如果你能告诉我如何在IOLoop中注入一些新的未来来解决这个问题，那就太好了。 我也尝试过使用tornados AsyncHTTPClient，与文档相反，它实际上没有使用yield，但在使用await时会返回响应。 有没有关于这方面的最新文档？所有示例都不适用于多个异步请求。 根据本文档http://w
浏览 11提问于2019-02-01得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
