Xarray Datasets from House Tables.

dask-ms的Python项目详细描述


https://img.shields.io/pypi/v/dask-ms.svghttps://img.shields.io/travis/ska-sa/dask-ms.svgDocumentation Status

通过python-casacore从casa表构造xarrayDatasetsDataset中包含的Variablesdask数组,由 对pyrap.tables.table.getcol的延迟调用。

支持将Variables写入表中的相应列。

这个包的目的是支持测量集 用于编写并行、分布式数据的数据源和接收器 射电天文学算法。

安装

使用xarray支持安装:

$ pip install dask-ms[xarray]

没有类似的xarray,但是复制了减少的数据集功能 在达斯克MS本身。专家用户可能希望使用此选项来减少 python包依赖项。

$ pip install dask-ms

示例用法

importdask.arrayasdafromdaskmsimportxds_from_table,xds_to_table# Create xarray datasets from Measurement Set "WSRT.MS"ds=xds_from_table("WSRT.MS")# Set the flag Variable on first Dataset to it's inverseds[0]['flag']=(ds[0].flag.dims,da.logical_not(ds[0].flag))# Write the flag column back to the Measurement Setxds_to_table(ds,"WSRT.MS","FLAG").compute()printds[<xarray.Dataset>Dimensions:(chan:64,corr:4,row:6552,uvw:3)Coordinates:ROWID(row)int32dask.array<shape=(6552,),chunksize=(6552,)>Dimensionswithoutcoordinates:chan,corr,row,uvwDatavariables:IMAGING_WEIGHT(row,chan)float32dask.array<shape=(6552,64),chunksize=(6552,64)>ANTENNA1(row)int32dask.array<shape=(6552,),chunksize=(6552,)>STATE_ID(row)int32dask.array<shape=(6552,),chunksize=(6552,)>EXPOSURE(row)float64dask.array<shape=(6552,),chunksize=(6552,)>MODEL_DATA(row,chan,corr)complex64dask.array<shape=(6552,64,4),chunksize=(6552,64,4)>FLAG_ROW(row)booldask.array<shape=(6552,),chunksize=(6552,)>CORRECTED_DATA(row,chan,corr)complex64dask.array<shape=(6552,64,4),chunksize=(6552,64,4)>PROCESSOR_ID(row)int32dask.array<shape=(6552,),chunksize=(6552,)>WEIGHT(row,corr)float32dask.array<shape=(6552,4),chunksize=(6552,4)>FLAG(row,chan,corr)booldask.array<shape=(6552,64,4),chunksize=(6552,64,4)>TIME(row)float64dask.array<shape=(6552,),chunksize=(6552,)>SIGMA(row,corr)float32dask.array<shape=(6552,4),chunksize=(6552,4)>SCAN_NUMBER(row)int32dask.array<shape=(6552,),chunksize=(6552,)>INTERVAL(row)float64dask.array<shape=(6552,),chunksize=(6552,)>OBSERVATION_ID(row)int32dask.array<shape=(6552,),chunksize=(6552,)>TIME_CENTROID(row)float64dask.array<shape=(6552,),chunksize=(6552,)>ARRAY_ID(row)int32dask.array<shape=(6552,),chunksize=(6552,)>ANTENNA2(row)int32dask.array<shape=(6552,),chunksize=(6552,)>DATA(row,chan,corr)complex64dask.array<shape=(6552,64,4),chunksize=(6552,64,4)>FEED1(row)int32dask.array<shape=(6552,),chunksize=(6552,)>FEED2(row)int32dask.array<shape=(6552,),chunksize=(6552,)>UVW(row,uvw)float64dask.array<shape=(6552,3),chunksize=(6552,3)>Attributes:FIELD_ID:0DATA_DESC_ID:0]

限制

  1. 许多测量集列被定义为可变形状, 但实际数据是固定的。 dask-ms将推断 第一行的数据必须一致 和其他排的一样。 例如,当多个光谱窗口 存在于具有不同通道的测量集中 根据SPW。

    dask-ms通过对 将测量集设置为多个数据集。 第一行的形状用于推断分区的形状。 因此,在多光谱窗口的情况下,我们可以划分 由数据描述ID设置的度量值,用于创建数据集 每个光谱窗口。

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
使用php调用java web服务时无法获取输出   java Netbeans:安装IMlet时出错。。。。仿真器错误   初始化期间Eclipse Juno SR 2中的java堆栈溢出   java在3d中寻找两个任意立方体的交集   代码中显示java“org.openqa.selenium.WebDriverException”错误   java使用AtomicInteger作为可变整数的替代品是一种好的做法吗?   当以编程方式设置背景颜色时,java版面在更新后会自动复制   java将字符串拆分为一个带有数字数据的字符串和另一个带有非数字数据的字符串   带有SSL协议的java AsyncHttpClient   C++服务器HTTN到java NtoHS客户端转换   java内存分配是基于引用类还是实例类?   java使用ProjectLombok安全吗?   grails“java版本”在命令提示符下不工作   java无法使用axis2实例化类型ADBDataSource   在Play Framework 2中进行多文件上传的java示例   java如何将二进制补码字符串转换为负十进制数?   windows 7在Java中获取不正确的操作系统名称   java如何禁用p:commandButton的enter键?   java如何从main方法加载servlet   java如何从imageView获取二进制位图