利用asyncio到GCS的可变映射接口
gcs-aio-mapper的Python项目详细描述
示例：
import zarr
from gcs_aio_mapper import GCSMapperAio
from gcsfs import GCSMap
import logging
logging.basicConfig(level=logging.DEBUG)
n = 25
def build_gs_async():
store = GCSMapperAio("gs://bucket/tmp/test.zarr", cache_size=n)
g = zarr.open_array(store, shape=(n,), chunks=(3,), mode="w")
for i in range(n):
g[i] = i
store.flush()
def build_gs():
store = GCSMap("gs://bucket/tmp/test.zarr")
g = zarr.open_array(store, shape=(n,), chunks=(3,), mode="w")
for i in range(n):
g[i] = i
- 项目
标签：
欢迎加入QQ群-->： 979659372
