Мне было интересно, существует ли способ потоковой передачи данных непосредственно из файла NetCDF, поскольку он записывается с помощью `xarray.
Я думаю, что могу" создать "небуферизованный файл, как этот?
import io
ts_file_stream = io.open("/some/file/being/written/to.nc", mode='rb', buffering=-1)
Я также знаю, что могу открыть это с помощью Xarray:
import xarray as xr
ds = xr.open_dataset(ts_file_stream)
Однако я не уверен, будут ли массивы постоянно обновляться? Цель всего этого заключается в следующем: у меня есть числовая модель, производящая вывод, и я хотел бы визуализировать некоторые переменные по мере запуска модели, чтобы получить представление о текущем состоянии. Я знаю, что это поддерживается людьми из Holoviews: https://hvplot.holoviz.org/user_guide/Streaming.html
Требуется ли для этого создание собственного потока с библиотекой streamz? https://streamz.readthedocs.io/en/latest/index.html
Любые советы о том, как заставить это работать для netcdf, были бы замечательными!
Приветствия,
Пол