我有一个numpy数组,它保存为未压缩的'*npz‘文件,大约是26个GiB,因为它是numpy.float32,numpy.savez()的结尾是:
OSError: Failed to write to /tmp/tmpl9v3xsmf-numpy.npy: 6998400000 requested and 3456146404 written我认为压缩后的保存可能会节省时间,但使用numpy.savez_compressed(),我还可以:
OSError: Failed to write to /tmp/tmp591cum2r-numpy.npy: 6998400000 requested and 3456157668 written因为numpy.savez_compressed()首先保存了未压缩的数组。
显而易见的“使用额外的存储”,我认为没有答案。;)
编辑
标记low-memory指的是磁盘内存,而不是内存。
发布于 2018-02-28 16:18:51
在Python3.6中添加ZipFile.open(..., mode='w'),您可以做得更好:
import numpy as np
import zipfile
import io
def saveCompressed(fh, **namedict):
with zipfile.ZipFile(fh, mode="w", compression=zipfile.ZIP_DEFLATED,
allowZip64=True) as zf:
for k, v in namedict.items():
with zf.open(k + '.npy', 'w', force_zip64=True) as buf:
np.lib.npyio.format.write_array(buf,
np.asanyarray(v),
allow_pickle=False)发布于 2018-02-28 13:36:04
注意:我非常乐意接受一个更高效的内存解决方案.
我浏览了numpy.savez_compressed()代码,并决定重新实现其部分功能:
import numpy as np
import zipfile
import io
def saveCompressed(fh, **namedict):
with zipfile.ZipFile(fh,
mode="w",
compression=zipfile.ZIP_DEFLATED,
allowZip64=True) as zf:
for k, v in namedict.items():
buf = io.BytesIO()
np.lib.npyio.format.write_array(buf,
np.asanyarray(v),
allow_pickle=False)
zf.writestr(k + '.npy',
buf.getvalue())它会导致我的系统交换,但至少我能够存储数据(示例中使用的假数据):
>>> A = np.ones(12 * 6 * 6 * 1 * 6 * 6 * 10000* 5* 9, dtype=np.float32)
>>> saveCompressed(open('test.npz', 'wb'), A=A)
>>> A = np.load('test.npz')['A']
>>> A.shape
(6998400000,)
>>> (A == 1).all()
Truehttps://stackoverflow.com/questions/49029309
复制相似问题