streaming-zarr-blog

conway.py

store = zarr.RedisStore(port=args.port)
root = zarr.group(store=store, overwrite=True)
t = 0
while True:
    arr = root.zeros(f"{t}", shape=grid.shape, chunks=(25, 25))  # create a new array for this timestep
    arr[…] = grid # write data to zarr array
    
    t += 1  # increment the time counter
    time.sleep(update_interval)
    grid = update(grid, N)  # evolve the model one time step