如何解决Dask - 如何从存储在 Zarr 中的一维数组子组创建二维数组
我正在尝试从存储在 Zarr 组中的所有子组中读取 N
行,并且使用 for 循环非常慢,所以有没有办法使用 dask(我对 dask 完全陌生并且可以找不到任何类似于我想做的事情)来实现这种相对快速且节省内存的方式
一些代码片段来帮助我尝试做的事情。
import os
import zarr
from numcodecs import Blosc,PackBits
import numpy as np
from multiprocessing import Process
# Zarr store related #
store_file = "data/bloomfilters.zarr"
store = zarr.DirectoryStore(store_file)
sync_dir = os.path.splitext(store_file)[0] + ".sync"
synchronizer = zarr.ProcessSynchronizer(sync_dir)
Blosc.use_threads = False
compressor = Blosc(cname="zstd",clevel=9,shuffle=Blosc.BITSHUFFLE)
root_group = zarr.group(store=store,synchronizer=synchronizer)
bf_group = root_group.create_group(name="BloomFilterIndex")
# Parallelize bloom filter writes to zarr #
# samples_list size is 215M sometimes even more
bloomfilter_size = 300000
n_cores = 64
processes = []
for samp_list in np.array_split(samples_list,n_cores):
proc = Process(target=write_bf_to_zarr,args=(bf_group,compressor,bloomfilter_size,samples_list))
proc.start()
processes.append(proc)
for proc in processes:
proc.join()
# Write function #
def write_bf_to_zarr(bf_group_handle,samples_list):
for sample_info in samples_list:
col_idx = sample_info[0]
file_paths = sample_info[1]
bloomfilter = bf_group_handle.zeros(
f"sample_{col_idx}",shape=(bloomfilter_size),chunks=(int(bloomfilter_size/4)),dtype="bool",filters=[PackBits()],compressor=compressor,)
# Note: bloomfilter_cython will create bloom filter as NumPy boolean array and will return it
bloomfilter[:] = bloomfilter_cython(file_paths,bloomfilter_size)
# To slice 'n' rows (example 10 rows) from each of the sub-group
m = len(bf_group.keys())
n = 10
n_rows = np.zeros((n,m),dtype=bool)
start = 0
stop = 10
for col_idx,key in enumerate(bf_group.keys()):
n_rows[:,col_idx] = bf_group.get(key)[start:stop]
因此,我不使用 for 循环,而是想知道是否有一种方法可以轻松提取 N
行,然后我可以简单地将其用作下游工作的 2D 矩阵。
或者: 了解如何在不消耗太多内存的情况下通过连接所有这些子组在磁盘上创建 2D 数组(可能作为 Zarr 存储)也很不错。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。