python - AttributeError:“str”对象没有属性“errno”
问题描述
我ClientConnectionError
在multiprocessing.Queue
由asyncio
. 我这样做是为了将在 asyncio 中生成的异常传递回另一个线程/进程中的客户端。
我的假设是这个异常发生在反序列化过程中,从队列中读取异常。否则看起来几乎不可能达到。
Traceback (most recent call last):
File "model_neural_simplified.py", line 318, in <module>
main(**arg_parser())
File "model_neural_simplified.py", line 314, in main
globals()[command](**kwargs)
File "model_neural_simplified.py", line 304, in predict
next_neural_data, next_sample = reader.get_next_result()
File "/project_neural_mouse/src/asyncs3/s3reader.py", line 174, in get_next_result
result = future.result()
File "/usr/lib/python3.6/concurrent/futures/_base.py", line 432, in result
return self.__get_result()
File "/usr/lib/python3.6/concurrent/futures/_base.py", line 384, in __get_result
raise self._exception
File "/usr/lib/python3.6/concurrent/futures/thread.py", line 56, in run
result = self.fn(*self.args, **self.kwargs)
File "model_neural_simplified.py", line 245, in read_sample
f_bytes = s3f.read(read_size)
File "/project_neural_mouse/src/asyncs3/s3reader.py", line 374, in read
size, b = self._issue_request(S3Reader.READ, (self.url, size, self.position))
File "/project_neural_mouse/src/asyncs3/s3reader.py", line 389, in _issue_request
response = self.communication_channels[uuid].get()
File "/usr/lib/python3.6/multiprocessing/queues.py", line 113, in get
return _ForkingPickler.loads(res)
File "/usr/local/lib/python3.6/dist-packages/aiohttp/client_exceptions.py", line 133, in __init__
super().__init__(os_error.errno, os_error.strerror)
AttributeError: 'str' object has no attribute 'errno'
我认为这是一个很长的问题,但是有人知道这个问题吗?
Python 3.6.8,aiohttp.__version__ == 3.6.0
更新:
我设法重现了这个问题(感谢 Samuel 在评论中改进了最小可重现测试用例,后来在 bugs.python.org 上的 xtreak 将其进一步提炼为仅用于 pickle 的测试用例):
import pickle
ose = OSError(1, 'unittest')
class SubOSError(OSError):
def __init__(self, foo, os_error):
super().__init__(os_error.errno, os_error.strerror)
cce = SubOSError(1, ose)
cce_pickled = pickle.dumps(cce)
pickle.loads(cce_pickled)
./python.exe ../backups/bpo38254.py
Traceback (most recent call last):
File "/Users/karthikeyansingaravelan/stuff/python/cpython/../backups/bpo38254.py", line 12, in <module>
pickle.loads(cce_pickled)
File "/Users/karthikeyansingaravelan/stuff/python/cpython/../backups/bpo38254.py", line 8, in __init__
super().__init__(os_error.errno, os_error.strerror)
AttributeError: 'str' object has no attribute 'errno'
参考:
解决方案
OSError
有一个自定义__reduce__
实现;不幸的是,对于与预期参数不匹配的子类,它不是子类友好的。__reduce__
手动调用可以看到酸洗的中间状态:
>>> SubOSError.__reduce__(cce)
(modulename.SubOSError, (1, 'unittest'))
的第一个元素tuple
是可调用的,第二个是tuple
要传递的参数。因此,当它尝试重新创建您的课程时,它会:
modulename.SubOSError(1, 'unittest')
丢失了有关OSError
您最初创建时使用的信息。
OSError.__reduce__
如果您必须接受与/预期不匹配的参数OSError.__init__
,您将需要编写自己的__reduce__
覆盖以确保正确的信息被腌制。一个简单的版本可能是:
class SubOSError(OSError):
def __init__(self, foo, os_error):
self.foo = foo # Must preserve information for pickling later
super().__init__(os_error.errno, os_error.strerror)
def __reduce__(self):
# Pickle as type plus tuple of args expected by type
return type(self), (self.foo, OSError(*self.args))
使用该设计,SubOSError.__reduce__(cce)
现在将返回:
(modulename.SubOSError, (1, PermissionError(1, 'unittest')))
其中 的第二个元素tuple
是重新创建实例所需的正确参数(从OSError
到的变化PermissionError
是预期的;OSError
实际上返回基于 的自己的子类errno
)。
推荐阅读
- node.js - PATH变量在电子中为空?
- python - 如何使用熊猫从数据框中删除多列(使用列名)?
- python - 过滤数据框,根据某些列的值显示行
- r - grid.Call(C_textBounds, as.graphicsAnnot(x$label), x$x, x$y, 中的警告:字符 0x20 的字体宽度未知
- apache-kafka - 使用不自动注册模式的 kafka-avro-console-producer
- excel - VBA 运行时错误 1004 - 变量有问题?
- angular - 当我单击隐藏和显示按钮时,提交了两次表单
- javascript - dispatchEvent 在 Internet Explorer 11 的 javascript 中不起作用
- sql - 如何在 Flask 应用程序中将可变参数插入 SQL 存储过程
- javascript - JavaScript,对象变量被声明为 NaN 的问题