Python:从引发TypeError的中间函数返回的异步生成器
在Python中，异步生成器是一种特殊的生成器，用于在异步编程中以异步的方式产生数据序列。它们可以与async/await语法结合使用，以便在异步代码中更方便地处理大量数据。
当一个函数在执行过程中包含了yield语句，那么它就是一个生成器函数。而当生成器函数中包含了async关键字，它就成为了一个异步生成器函数。
在上述问答中，提到了一个从引发TypeError的中间函数返回的异步生成器。这意味着在某个函数执行的过程中，引发了一个TypeError异常，并且这个函数是一个中间函数（在其他函数中被调用的函数）。而这个中间函数返回的结果是一个异步生成器。
具体来说，中间函数可能包含一系列的yield语句，用于产生数据。当发生TypeError异常时，这个函数会停止执行并抛出异常。然后，可以通过异步生成器的send()方法或者在async/await语法中使用for循环，从异常中恢复并继续生成数据。
异步生成器在异步编程中具有很多优势和应用场景。它们可以用于处理大量的异步数据，比如从网络或数据库中读取数据。通过异步生成器，可以将数据的获取和处理过程分离，使得代码更加清晰和可维护。
腾讯云提供了一系列适用于异步编程的产品和服务，例如云函数（https://cloud.tencent.com/product/scf）和云数据库（https://cloud.tencent.com/product/cdb），它们可以与Python的异步生成器结合使用，以构建高效的异步应用程序。
总结起来，Python的异步生成器是一种在异步编程中处理数据序列的强大工具。通过使用异步生成器，可以更好地处理大量的异步数据，并使代码更加清晰和可维护。腾讯云提供了适用于异步编程的产品和服务，可以与Python的异步生成器相结合，以构建高效的异步应用程序。
相关·内容
4回答
假设我们在Python3.x(我猜在Python2.6和Python2.7中也有)中有以下函数：
>>> def dbl_a(p): return p*2
>>> def dbl_b(p): return(p*2)
>>> def dbl_c(p): return (p*2)
如果我们对他们进行调查，我们会得到：
>>> dbl_a(42)
84
>>> dbl_b(42)
84
>>> dbl_c(42)
84
这三个函数提供相同的结果(值和类型)，它们似乎是等价的。
但是他们中的哪一
浏览 6提问于2011-02-12得票数 54
回答已采纳
2回答
我正在尝试将类型添加到返回生成器的方法中。每当我使用指定的返回类型运行此程序时，都会引发TypeError。
添加引号或删除输入可以修复错误，但这看起来像是hack。当然，有一种正确的方法可以做到这一点。
def inbox_files(self) -> "Generator[RecordsFile]":
...
# OR
def inbox_files(self):
...
from typing import Generator, List
from .records_file import RecordsFile
Class Marshalle
浏览 0提问于2019-08-06得票数 18
我正在尝试使用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
回答已采纳
如果我尝试在Python中运行以下代码，将得到以下错误：
async def foo():
yield 1
async def bar():
x = await foo()
b=bar()
b.send(None)
TypeError:对象async_generator不能用于“等待”表达式
另一方面，以下代码可以工作(并抛出一个StopIteration，但这是预期的)：
async def foo():
pass
async def bar():
await foo()
b=bar()
b.send(None)
为什么这个不行？
如果我将foo替
浏览 2提问于2017-09-29得票数 1
2回答
我一定要写吗
def count10():
for i in range(10):
yield i
gen = count10()
for j in gen:
print(j)
gen.close()
为了节省内存，或者只是
def count10():
for i in range(10):
yield i
for j in count10():
print(j)
事实上，我很想了解Python生成器生命周期的详细信息，但找不到相关的资源。
浏览 1提问于2020-07-16得票数 1
我正在尝试将我的应用程序从python2.7迁移到python3.6，用于asyncio和relates，但我发现一些功能并不像我所期望的那样工作。我使用motor异步查询mongodb，如下所示：
async def do_query():
song_already_processed = set()
song_table = db.song_table
async for index, item in enumerate(song_table.find({'lang': 'English'},
浏览 3提问于2018-01-03得票数 5
2回答
如果我做了这样的事
>>> x = int(1,2,3,4,5)
我立即得到一个致命的错误(如果是在预先编写的脚本中，就会终止程序的执行)。
Traceback (most recent call last):
File "<stdin>", line 1, in <module>
TypeError: int() takes at most 2 arguments (5 given)
x仍未定义：
>>> x
Traceback (most recent call last):
File
浏览 2提问于2013-11-27得票数 19
回答已采纳
2回答
(以下代码可以在木星中运行。)我有一个B类，它使用A类，需要测试。
class A:
async def f(self):
pass
class B:
async def f(self):
a = A()
x = await a.f() # need to be patched/mocked
我有下面的测试代码。它似乎模拟了A的类方法，而不是实例方法。
from asyncio import Future
from unittest.mock import MagicMock, Mock, patch
async def t
浏览 15提问于2022-02-05得票数 2
回答已采纳
1回答
我创建了一个小小的python函数，它提供了一个简单的检查:参数n是自然数吗？一般来说，你是如何完成这项检查的？
这是我创建的代码：
def is_natural_number(n, print_err_msg=True):
try:
if not isinstance(n, int):
raise TypeError("Your input is not of integer type.")
if n < 1:
raise ValueError("Your integer i
浏览 4提问于2016-12-30得票数 2
回答已采纳
我正在尝试创建一组目录，这在Python和R中是非常简单的，有人知道如何在Julia中这样做吗？我看了看朱莉娅的手册，什么也没有从我身上跳出来。谢谢。蔡斯CB
浏览 1提问于2014-02-24得票数 12
回答已采纳
4回答
在Python中使用相同的函数(如下面所示)时，究竟会发生什么？
def find_all(a_str, sub):
start = 0
while True:
start = a_str.find(sub, start)
if start == -1: return
yield start
start += len(sub) # use start += 1 to find overlapping matches
它还是发电机吗？
浏览 0提问于2014-10-27得票数 96
回答已采纳
现在我正在研究yield from和await语法之间的区别。从python官方文档中可以看出，yield-from生成器()只是以下代码的语法糖：
for i in generator(): yield i
但是我不能在下面的例子中去掉其值。
def accumlate():
# context
accumlator = 0
while True:
next = yield
if next is None:
return accumlator
accumlator += next
def ga
浏览 2提问于2019-09-24得票数 3
2回答
在使用响应对象时，我试图捕获异常。我的用例是，我希望像在中所描述的那样对数据进行流，并且当我获得想要流的数据时，可能会出现异常：
# test.py
from flask import Flask, Response, jsonify
import werkzeug
app = Flask(__name__)
@app.route("/")
def hello():
def generate():
raise Exception
浏览 1提问于2018-11-26得票数 1
我正在使用python grouper 提供的修改后的菜谱。
from itertools import chain, islice
def grouper(iterable, n):
iterable = iter(iterable)
while True:
peek = next(iterable)
yield chain((peek,), islice(iterable, n - 1))
这看起来挺好的。我可以做这样的事情：
>>> x = bytearray(range(16))
>>> [int.fr
浏览 9提问于2017-08-10得票数 2
回答已采纳
我是Python的新手。我在创建熊猫数据框时遇到了麻烦。
dataDict = {}
dataDict['grant_id'] = grant_ids
dataDict['patent_title'] = patent_title
dataDict['kind'] = kinds
df=pd.DataFrame(dataDict)
上面的代码可以在python2中运行，但是当我切换到python3时，我得到了错误消息：
TypeError Traceback (most recent call last)
<ipython-input-6
浏览 0提问于2019-08-13得票数 0
我正在测试一个我从C重写到Python的模块，并且有一个我在职业生涯中见过的奇怪的bug。带有测试的令人不快的Python代码只有三行：
# MATCHERS is a list of compiled regular expression objects defined as a
# global in the top level of the module
print dir(MATCHERS[0])
# diff.Differ is a class implemented in C with thed Python API; zoneA/B Words are
# lists and C
浏览 0提问于2013-01-30得票数 1
回答已采纳
如果我在Python中有一个常规的可迭代对象，我可以使用any和生成器理解来获得布尔值。例如。
from pathlib import Path
path = Pathlib("/foo/bar/baz")
has_contents = any(path.iterdir())
我也可以用async_generator和列表理解做同样的事情：
is_empty = any([x async for x in async_generator])
但是，对async_generator和生成器的理解似乎不可能做到同样的事情。
not_empty = any(x async for
浏览 30提问于2022-04-25得票数 1
回答已采纳
1回答
我已经向我的Startup类添加了一个自定义中间件(遵循示例)。
public void Configure(IApplicationBuilder app, IHostingEnvironment env)
{
app.Use((context, next) =>
{
try { return next(); }
catch (Exception exception) { return new Task(() => { }); }
});
app.UseCors("Welcome All");
app.UseMvc();
浏览 0提问于2018-01-10得票数 2
回答已采纳
我相信seaborn想要RGBA颜色格式，所以我给了它一个RGBA元组列表，就像在matplotlib中一样，但它不喜欢。我尝试过像g = sns.jointplot(plotdataandstuff)这样的操作，但是我不知道如何在<seaborn.axisgrid.JointGrid at 0x135943d30>对象中导航
u = np.array([ 3.41959, 1.79315, 1.17229, 1.59909, 1.27337, 1.21917, 2.60591, 2.0571 , 1.83865, 1.94869])
v = np.array([238614, 1
浏览 13提问于2017-01-26得票数 3
1回答
这是我在django 1.6 (工作良好)中的代码，我升级到django 1.7。第一个simplejson是实际的:我将simplejson更改为json，但是我收到的错误总是不能被json序列化。
有什么想法吗？
视图：
def request_to_json(request):
post_data = request.body
json_data = simplejson.loads(post_data)
return json_data
def receiver(request):
try:
json_data = requ
浏览 0提问于2014-09-13得票数 0
1回答
我有一个长期运行的程序，我想保持响应。该算法是递归的，因此有时即使是运行时间较长的调用中的子任务也可能比较短的整个运行时间更长。我试图让它使用yield，但最终得到的结果是列表中充满了各级递归列表结构的生成器(列表也是多级层次结构，记录调用的深度)。我最终制作了简单的打印答案版本，但它最终打印出了答案。我不能只打印递归调用的结果，而且结果需要在打印之前进行后处理。
有没有一种简单的模式，让顶级函数调用来产生值，而递归调用来返回答案？我应该在递归调用结果上使用for循环，还是应该从递归调用中生成aswer的list()？我是否应该只放入深度参数，返回深度> 0，并在深度为0的情况下返回？
浏览 0提问于2010-10-10得票数 3
与下面的示例一样，我在使用异步生成器时遇到了一个不寻常的错误。
async def demo():
async def get_data():
for i in range(5): # loop: for or while
await asyncio.sleep(1) # some IO code
yield i
datas = get_data()
await asyncio.gather(
anext(datas),
anext(datas),
浏览 8提问于2022-05-11得票数 2
3回答
我正在尝试从CSV文件中创建一个包含784位长行的数据集。这是我的密码：
import tensorflow as tf
f = open("test.csv", "r")
csvreader = csv.reader(f)
gen = (row for row in csvreader)
ds = tf.data.Dataset()
ds.from_generator(gen, [tf.uint8]*28**2)
我得到以下错误：
----------------------------------------------------------------
浏览 1提问于2018-03-14得票数 15
回答已采纳
def prefixes(s):
if s:
yield from prefixes(s[:-1])
yield s
t = prefixes('both')
next(t)
下一个(T)返回'b‘。我只是搞不懂为什么会这样，因为如果我们继续执行yield from语句，我们最终会在返回None的yield from prefixes('')结束。在我的所有其他测试中，都没有引发TypeError。相反，这似乎被忽略了，前缀(‘b’)移到了下一个yield语句(？它为什么要这样做？)产生“b”..。有什么想法可以
浏览 0提问于2020-04-20得票数 0
作为学习Python的练习，我尝试编写了一个float_range()迭代器，它模仿range()，但允许使用浮点数。我尝试捕获错误数量的参数来引发TypeError，并编写了下面的函数。 def float_range(*args):
start = 0.0
step = 1.0
if len(args) == 3:
start, end, step = args
elif len(args) == 2:
start, end = args
elif len(args) == 1:
(en
浏览 9提问于2020-09-11得票数 1
回答已采纳
我想从一个删减员那里得到模因。问题是，当我尝试使用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
回答已采纳
2回答
考虑以下Python代码：
def values():
with somecontext():
yield 1
yield 2
for v in values():
print(v)
break
在这种情况下，Python是否保证生成器正确关闭，从而退出上下文？
我意识到，在实践中，由于引用计数和生成器的急切销毁，在CPython中会出现这种情况，但是Python能保证这种行为吗？我确实注意到它确实不能在Jython中工作，所以这应该被认为是一个bug或允许的行为吗？
浏览 0提问于2015-03-14得票数 5
4回答
我正在使用python3.5。当我试图返回生成器函数实例时，我得到了一个StopIteration错误。为什么？
这是我的代码：
>>> def gen(start, end):
... '''generator function similar to range function'''
... while start <= end:
... yield start
... start += 1
...
>>> def check(ingen, flag=None):
...
浏览 10提问于2016-08-12得票数 0
回答已采纳
1回答
我编写了C++ DLL，它位于MetaTrader4aplation (MT4)和Python (将PythontoMT4嵌入)之间。MT4向该DLL发送请求并等待指令执行(例如字符串命令数组)。DLL将MT4请求的解析传递给Python脚本。Python脚本需要从MT4获得一些信息来解析每个请求。因此，MT4和Python具有双向通信。
但是MT4不支持双向通信，它只能解析自己的DLL请求的结果，并使用新的参数对DLL进行新的调用。因此，我需要中断Python控制流，将部分结果从Python (和MT4)返回到DLL (和MT4 )，等待来自MT4的新请求。
我如何在Python风格中创建这
浏览 3提问于2014-01-02得票数 0
回答已采纳
我已经阅读了django的管理视图的源代码，视图不接受关键字参数。
现在的问题是，除了扩展django的默认视图之外，我如何将自己的变量传递给django的管理视图？
我不想改变默认视图和它的url设置，我可以用其他方式扩展它吗？
我编写了自己的django中间件，将我的公共变量传递给我的所有视图。
但是，之后，当我使用djano管理视图时，遇到django得到了意想不到的关键字参数。
我在这个问题上找不到任何帮助，从django的文档中也找不到例子。
下面的链接是我发现的。
我将在下面列出我的代码：
middleware.py
from blog.data import (Use
浏览 3提问于2013-11-15得票数 1
回答已采纳
所以我对生成器进行了修改，我发现生成器有一个typing对象(即生成器有一个别名)，然后我偶然发现了上的typing.Generator对象的文档，这就是文档必须说的：
生成器可以由泛型Generator[YieldType, SendType, ReturnType]__注释。
这让我想知道如何修改SendType和ReturnType thingys文档，举个例子：
def echo_round() -> Generator[int, float, str]:
sent = yield 0
while sent >= 0:
sent = yie
浏览 3提问于2022-05-02得票数 3
回答已采纳
以下异步生成器代码直接从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
回答已采纳
我看了几个其他的答案，但他们对我没有帮助。
节点版本16.8.0 windows 10 "got"："11.8.2"，电子14.0.0
这是我正在尝试的。下面的代码确实下载了该文件，但是createWriteStream抛出了错误--
TypeError ERR_INVALID_RETURN_VALUE:期望从“目的”函数返回的AsyncIterable或承诺，但类型未定义。
我的渲染文件中的代码
module.exports.getTile = async function (url, outputFilePath) {
const pipel
浏览 9提问于2021-09-10得票数 1
回答已采纳
我正在尝试使用带有scrapy的中间件，因此在我的项目“教程”中，我已经这样做了：
在设置文件中添加：
DOWNLOADER_MIDDLEWARES = {
'scrapy.contrib.downloadermiddleware.httpproxy.HttpProxyMiddleware': 110,
'tutorial.middlewares.ProxyMiddleware': 100,
}
并创建一个名为middlewares.py的文件，该文件包含以下内容：
import base64
# Start your middleware class
cla
浏览 3提问于2015-12-12得票数 2
回答已采纳
该代码应该从数据(数据)中生成一个向量字段，该数据描述了访问单元格的频率。
def vectorfield(maze, walk, data):
# associate a zero vector with each location in walkable space
tempdata = {pair:np.zeros(2) for pair in walk}
for x, y in tempdata.keys():
value = data[x][y] # how many times an agent visited this cell
浏览 3提问于2022-08-16得票数 1
回答已采纳
2回答
通过使用next()内置函数，可以逐步迭代生成器.例如：
def sync_gen(n):
"""Simple generator"""
for i in range(n):
yield i**2
sg = sync_gen(4)
print(next(sg)) # -> 0
print(next(sg)) # -> 1
print(next(sg)) # -> 4
在异步生成器上使用next()不起作用：
import asyncio
async def async_gen(n):
浏览 4提问于2020-09-13得票数 7
回答已采纳
在这段代码中，为什么使用for不会产生StopIteration，或者for循环捕获所有异常，然后静默退出？在这种情况下，为什么我们会有无关的return？或者是return None引起的raise StopIteration？
#!/usr/bin/python3.1
def countdown(n):
print("counting down")
while n >= 9:
yield n
n -= 1
return
for x in countdown(10):
print(x)
c = coun
浏览 5提问于2013-01-19得票数 82
回答已采纳
3回答
我正在读比尔·卢巴诺维奇的“介绍Python”，它说
像zip()一样，range()返回一个可迭代对象，
但这不是一个错误的说法吗？例如,
s= zip([1,2,3],['one','two','three'])
next(s)
>> (1,'one')
next(s)
>> (2,'two')
a = range(10)
next(a)
----------------------------------------------------------------------
浏览 1提问于2017-08-26得票数 2
回答已采纳
下面的代码得到了TypeError: 'async_generator' object is not iterable的错误
async def f(i):
return i*10, i*100
l2 = [1,2,3]
[x for x in ((i, await f(i)) for i in l2)]
但是，如果不使用生成器，它可以工作吗？
[x for x in [(i, await f(i)) for i in l2]]
浏览 6提问于2020-12-06得票数 0
回答已采纳
2回答
我有一个名为x的函数，它生成这样的生成器：
a = 5
def x():
global a
if a == 3:
raise Exception("Stop")
a = a - 1
yield a
然后，在python shell中，我像这样调用这个函数：
>>> print x().next()
>>> 4
>>> print x().next()
>>> 3
>>> print x().next()
>>> <py
浏览 0提问于2013-09-10得票数 3
回答已采纳
3回答
异步/等待不等待承诺解决
、、、
看来，我对await的使用并不是我所理解的那样。
我认为async函数和await关键字可以用于返回诺言(例如navigator.mediaDevices.getUserMedia)的调用，它会暂停函数的执行(就像生成器函数)，直到允诺得到解析，然后继续执行该函数。
尽管我在等待呼叫，但它马上就回来了，我的控制台日志也出现了故障。具体来说，以"reducer“开头的控制台日志出现在以"getter”开头的控制台中，而它应该是相反的/与(我认为)堆栈跟踪应该运行的方式相反。
有人能告诉我这是怎么回事吗？
异步辅助函数getter：
const getLocalStream = a
浏览 1提问于2018-02-16得票数 5
回答已采纳
1回答
我在python中有一个coroutine (增强生成器)，在数据结束后执行一些代码：
def mycoroutine():
try:
while True:
data = (yield)
print data
finally:
raise ValueError
print "END"
co = mycoroutine()
co.next()
for i in (1,2,3):
co.send(i)
不会引发ValueError异常，但解释器只需打印：
Exception ValueError: ValueErro
浏览 6提问于2013-09-05得票数 9
1回答
我在一个项目中看到，副作用的行为是在这样的操作中定位的：
// ...in ItemListPage.js
function onCreateItem (name, title, content) {
this.props.dispatch(createItem({ name, title, content }));
};
// ...in ItemActions.js
function createItem(post) {
return (dispatch) => {
return callApi('items', 'create
浏览 1提问于2017-07-17得票数 0
回答已采纳
我正在尝试以下几点：
class Payload_Session_Generator:
def __init__(self):
pass
async def __anext__(self):
async for payload in generate_fb_payload():
if type(payload) != str:
yield payload
else:
StopAsyncIteration
def __aite
浏览 4提问于2021-09-16得票数 5
2回答
既然range对象是可订阅的，为什么itertools.repeat对象不能订阅？
In [10]: range(3, 10)[3]
Out[10]: 6
In [11]: import itertools as it
In [12]: it.repeat(5)[3]
---------------------------------------------------------------------------
TypeError Traceback (most recent call last)
<ipython
浏览 3提问于2012-11-23得票数 2
1回答
我已经编写了一个递归算法来遍历Python中的嵌套迭代器。我不明白为什么它能成功地打印出元素，但却不能生成它们作为生成器。 虽然我已经成功地打印出了元素： tree = [[1,2],[3,[['abcde',['f']],'gh']]]
def traverse_printing(parent):
try:
for child in parent:
traverse(child)
except TypeError:
print(parent)
浏览 16提问于2019-01-14得票数 2
2回答
您能使用产率来进行一个非异步的方法调用吗？
生成器函数
function* generatorFunction () {
var asyncResult = yield doSomethingAsync();
console.log(asyncResult)
var nonAsyncResult = yield doSomethingNonAsync();
console.log(nonAsyncResult)
}
支持方法
function doSomethingAsync() {
axios
.get("https://jsonpl
浏览 0提问于2018-05-25得票数 2
回答已采纳
我写了一个关于Python生成器的测试程序。但是我得到了一个意外的错误。我不知道该怎么解释。让我给你展示一下代码：
def countdown(n):
logging.debug("Counting down")
while n > 0:
try:
yield n
except GeneratorExit:
logging.error("GeneratorExit")
n -= 1
if __name__ == '__main__&#
浏览 0提问于2015-06-16得票数 9
在Python3中，我们使用了yield from关键字，它有助于在其他yield语句之间拼接现有迭代器的内容。但是，如果我们只想从现有的迭代器中获得所有的结果，我们可以使用yield from iterable或简单的return iterable实现相同的结果。显然，如果您需要您的代码在Python2和Python3中工作，那么您将被锁定在return选项中。但是，如果您只想获得Python 3，那么是否有充分的理由选择一个而不是另一个呢？yield from版本的优点是，对于任何阅读此函数返回迭代器的代码的人来说，这都是显而易见的。另一方面，我认为yield from的简单实现可能比简单
浏览 2提问于2017-05-05得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
