cassandra数据源
<p>[TOC]</p>
<p>cassandra数据源属性列表详见：<a href="https://www.showdoc.com.cn/metdig/5110392719553594" title="cassandra数据源属性列表">cassandra数据源属性列表</a></p>
<h1>读取单层单时次模式网格数据</h1>
<p>单层单时次模式网格数据读取接口代码示例如下：</p>
<pre><code class="language-python">get_model_grid(init_time=None, fhour=None, data_name=None, var_name=None, level=None, extent=None, x_percent=0, y_percent=0)</code></pre>
<p><font size="4"><b>参数说明</b></font></p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数</th>
<th style="text-align: left;">必选</th>
<th style="text-align: left;">类型</th>
<th style="text-align: left;">默认</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">init_time</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">datetime</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">起报时间</td>
</tr>
<tr>
<td style="text-align: left;">fhour</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">int32</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">预报时效</td>
</tr>
<tr>
<td style="text-align: left;">data_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">模式名</td>
</tr>
<tr>
<td style="text-align: left;">var_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">数据要素名</td>
</tr>
<tr>
<td style="text-align: left;">level</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">int32</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">层次，None代表地面层</td>
</tr>
<tr>
<td style="text-align: left;">extent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">tuple</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">裁剪区域，如(50, 150, 0, 65)</td>
</tr>
<tr>
<td style="text-align: left;">x_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">number</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域经度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">y_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">number</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域纬度方向扩充百分比</td>
</tr>
</tbody>
</table>
<table>
<thead>
<tr>
<th style="text-align: left;">返回值</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">stda</td>
<td style="text-align: left;">STDA格式数据</td>
</tr>
</tbody>
</table>
<p><font size="4"><b>调用示例</b></font></p>
<pre><code class="language-python">import datetime
from metdig.io.cassandra import get_model_grid
init_time = datetime.datetime(2020, 7, 25, 8)
fhour = 0
level = 500
data = get_model_grid(data_name='ecmwf', var_name='hgt', init_time=init_time, fhour=fhour, level=level)
print(data)
print(data.attrs)</code></pre>
<p><font size="4"><b>输出信息</b></font></p>
<pre><code class="language-python"><xarray.DataArray (member: 1, level: 1, time: 1, dtime: 1, lat: 451, lon: 901)>
array([[[[[[586.84216, 586.84216, 586.7922 , ..., 587.7422 ,
587.7422 , 587.7422 ],
[586.84216, 586.7922 , 586.7922 , ..., 587.6422 ,
587.6422 , 587.6422 ],
[586.84216, 586.7922 , 586.7922 , ..., 587.5422 ,
587.5422 , 587.5422 ],
...,
[566.9922 , 566.9922 , 567.0422 , ..., 538.2922 ,
538.2422 , 538.1422 ],
[566.9922 , 567.0422 , 567.09216, ..., 537.84216,
537.7422 , 537.6922 ],
[566.9922 , 567.0422 , 567.09216, ..., 537.4922 ,
537.3922 , 537.2922 ]]]]]], dtype=float32)
Coordinates:
* member (member) <U5 'ecmwf'
* level (level) int32 500
* time (time) datetime64[ns] 2020-07-25T08:00:00
* dtime (dtime) int32 0
* lat (lat) float64 -10.0 -9.8 -9.6 -9.4 -9.2 ... 79.4 79.6 79.8 80.0
* lon (lon) float64 0.0 0.2 0.4 0.6 0.8 ... 179.2 179.4 179.6 179.8 180.0
Attributes:
var_name: hgt
var_cn_name: 位势高度
var_units: dagpm
valid_time: 0
data_source: cassandra
level_type: high</code></pre>
<h1>读取单层多时次模式网格数据</h1>
<p>单层多时次模式网格数据读取接口代码示例如下：</p>
<pre><code class="language-python">get_model_grids(init_time=None, fhours=None, data_name=None, var_name=None, level=None, extent=None, x_percent=0, y_percent=0)</code></pre>
<p><font size="4"><b>参数说明</b></font></p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数</th>
<th style="text-align: left;">必选</th>
<th style="text-align: left;">类型</th>
<th style="text-align: left;">默认</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">init_time</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">datetime</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">起报时间</td>
</tr>
<tr>
<td style="text-align: left;">fhours</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">list</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">预报时效</td>
</tr>
<tr>
<td style="text-align: left;">data_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">模式名</td>
</tr>
<tr>
<td style="text-align: left;">var_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">要素名</td>
</tr>
<tr>
<td style="text-align: left;">level</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">int32</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">层次，None代表地面层</td>
</tr>
<tr>
<td style="text-align: left;">extent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">tuple</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">裁剪区域，如(50, 150, 0, 65)</td>
</tr>
<tr>
<td style="text-align: left;">x_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">number</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域经度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">y_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">number</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域纬度方向扩充百分比</td>
</tr>
</tbody>
</table>
<table>
<thead>
<tr>
<th style="text-align: left;">返回值</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">stda</td>
<td style="text-align: left;">STDA格式数据</td>
</tr>
</tbody>
</table>
<p><font size="4"><b>调用示例</b></font></p>
<pre><code class="language-python">import datetime
from metdig.io.cassandra import get_model_grids
init_time = datetime.datetime(2020, 7, 20, 8)
fhours = [0, 24]
level = 500
data = get_model_grids(init_time=init_time, fhours=fhours, data_name='ecmwf', var_name='hgt', level=level)
print(data)
print(data.attrs)</code></pre>
<p><font size="4"><b>输出信息</b></font></p>
<pre><code class="language-python"><xarray.DataArray (member: 1, level: 1, time: 1, dtime: 2, lat: 281, lon: 361)>
array([[[[[[582.95154, 583.0016 , 582.9891 , ..., 588.01404,
587.9391 , 587.8766 ],
[582.91406, 582.9391 , 582.91406, ..., 587.95154,
587.88904, 587.82654],
[582.82654, 582.8141 , 582.77655, ..., 587.88904,
587.85156, 587.82654],
...,
[575.33905, 575.3141 , 575.27655, ..., 573.8766 ,
573.63904, 573.41406],
[575.4891 , 575.45154, 575.40155, ..., 574.01404,
573.8141 , 573.6141 ],
[575.47656, 575.4391 , 575.38904, ..., 574.1891 ,
574.0016 , 573.77655]],
[[582.466 , 582.516 , 582.44104, ..., 587.2785 ,
587.2285 , 587.241 ],
[582.2035 , 582.266 , 582.2785 , ..., 587.25354,
587.216 , 587.216 ],
[582.00354, 582.0285 , 582.1035 , ..., 587.241 ,
587.2285 , 587.216 ],
...,
[575.4535 , 575.516 , 575.591 , ..., 577.56604,
577.391 , 577.19104],
[575.791 , 575.8535 , 575.9035 , ..., 577.8035 ,
577.641 , 577.4535 ],
[576.12854, 576.1785 , 576.2285 , ..., 578.016 ,
577.866 , 577.69104]]]]]], dtype=float32)
Coordinates:
* lat (lat) float64 -10.0 -9.75 -9.5 -9.25 -9.0 ... 59.25 59.5 59.75 60.0
* lon (lon) float64 60.0 60.25 60.5 60.75 ... 149.3 149.5 149.8 150.0
* time (time) datetime64[ns] 2020-07-20T08:00:00
* member (member) <U5 'ecmwf'
* level (level) int32 500
* dtime (dtime) int64 0 24
Attributes:
var_name: hgt
var_cn_name: 位势高度
var_units: dagpm
valid_time: 0
data_source: cassandra
level_type: high</code></pre>
<h1>读取多层单时次模式网格数据</h1>
<p>多层单时次模式网格数据读取接口代码示例如下：</p>
<pre><code class="language-python">get_model_3D_grid(init_time=None, fhour=None, data_name=None, var_name=None, levels=None, extent=None, x_percent=0, y_percent=0)</code></pre>
<p><font size="4"><b>参数说明</b></font></p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数</th>
<th style="text-align: left;">必选</th>
<th style="text-align: left;">类型</th>
<th style="text-align: left;">默认</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">init_time</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">datetime</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">起报时间</td>
</tr>
<tr>
<td style="text-align: left;">fhour</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">int32</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">预报时效</td>
</tr>
<tr>
<td style="text-align: left;">data_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">模式名</td>
</tr>
<tr>
<td style="text-align: left;">var_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">要素名</td>
</tr>
<tr>
<td style="text-align: left;">levels</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">list</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">层次，None代表地面层</td>
</tr>
<tr>
<td style="text-align: left;">extent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">tuple</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">裁剪区域，如(50, 150, 0, 65)</td>
</tr>
<tr>
<td style="text-align: left;">x_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">number</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域经度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">y_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">number</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域纬度方向扩充百分比</td>
</tr>
</tbody>
</table>
<table>
<thead>
<tr>
<th style="text-align: left;">返回值</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">stda</td>
<td style="text-align: left;">STDA格式数据</td>
</tr>
</tbody>
</table>
<p><font size="4"><b>调用示例</b></font></p>
<pre><code class="language-python">import datetime
from metdig.io.cassandra import get_model_3D_grid
init_time = datetime.datetime(2020, 7, 25, 8)
fhour = 0
levels = [1000, 950, 925, 900, 850, 800, 700, 600, 500, 400, 300, 250, 200, 100]
data = get_model_3D_grid(init_time=init_time, fhour=fhour, data_name='ecmwf', var_name='hgt', levels=levels)
print(data)
print(data.attrs)</code></pre>
<p><font size="4"><b>输出信息</b></font></p>
<pre><code class="language-python"><xarray.DataArray (member: 1, level: 14, time: 1, dtime: 1, lat: 451, lon: 901)>
array(......, dtype=float32)
Coordinates:
* member (member) <U5 'ecmwf'
* lon (lon) float64 0.0 0.2 0.4 0.6 0.8 ... 179.2 179.4 179.6 179.8 180.0
* lat (lat) float64 -10.0 -9.8 -9.6 -9.4 -9.2 ... 79.4 79.6 79.8 80.0
* time (time) datetime64[ns] 2020-07-25T08:00:00
* dtime (dtime) int32 0
* level (level) int64 1000 950 925 900 850 800 ... 500 400 300 250 200 100
Attributes:
var_name: hgt
var_cn_name: 位势高度
var_units: dagpm
valid_time: 0
data_source: cassandra
level_type: high</code></pre>
<h1>读取多层多时次模式网格数据</h1>
<p>多层多时次模式网格数据读取接口代码示例如下：</p>
<pre><code class="language-python">get_model_3D_grids(init_time=None, fhours=None, data_name=None, var_name=None, levels=None, extent=None, x_percent=0, y_percent=0)</code></pre>
<p><font size="4"><b>参数说明</b></font></p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数</th>
<th style="text-align: left;">必选</th>
<th style="text-align: left;">类型</th>
<th style="text-align: left;">默认</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">init_time</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">datetime</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">起报时间</td>
</tr>
<tr>
<td style="text-align: left;">fhours</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">list</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">预报时效</td>
</tr>
<tr>
<td style="text-align: left;">data_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">模式名</td>
</tr>
<tr>
<td style="text-align: left;">var_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">要素名</td>
</tr>
<tr>
<td style="text-align: left;">levels</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">list</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">层次，None代表地面层</td>
</tr>
<tr>
<td style="text-align: left;">extent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">tuple</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">裁剪区域，如(50, 150, 0, 65)</td>
</tr>
<tr>
<td style="text-align: left;">x_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">number</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域经度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">y_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">number</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域纬度方向扩充百分比</td>
</tr>
</tbody>
</table>
<table>
<thead>
<tr>
<th style="text-align: left;">返回值</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">stda</td>
<td style="text-align: left;">STDA格式数据</td>
</tr>
</tbody>
</table>
<p><font size="4"><b>调用示例</b></font></p>
<pre><code class="language-python">import datetime
from metdig.io.cassandra import get_model_3D_grids
init_time = datetime.datetime(2020, 7, 25, 8)
fhours = [0, 24]
levels = [1000, 950, 925, 900, 850, 800, 700, 600, 500, 400, 300, 250, 200, 100]
data = get_model_3D_grids(init_time=init_time, fhours=fhours, data_name='ecmwf', var_name='hgt', levels=levels)
print(data)
print(data.attrs)</code></pre>
<p><font size="4"><b>输出信息</b></font></p>
<pre><code class="language-python"><xarray.DataArray (member: 1, level: 14, time: 1, dtime: 2, lat: 451, lon: 901)>
array(......, dtype=float32)
Coordinates:
* member (member) <U5 'ecmwf'
* lon (lon) float64 0.0 0.2 0.4 0.6 0.8 ... 179.2 179.4 179.6 179.8 180.0
* lat (lat) float64 -10.0 -9.8 -9.6 -9.4 -9.2 ... 79.4 79.6 79.8 80.0
* time (time) datetime64[ns] 2020-07-25T08:00:00
* dtime (dtime) int32 0
* level (level) int64 1000 950 925 900 850 800 ... 500 400 300 250 200 100
Attributes:
var_name: hgt
var_cn_name: 位势高度
var_units: dagpm
valid_time: 0
data_source: cassandra
level_type: high</code></pre>
<h1>读取单层/多层，单时效/多时效模式网格数据并插值到站点</h1>
<p>读取单层/多层，单时效/多时效模式网格数据，并插值到站点上。接口代码示例如下：</p>
<pre><code class="language-python">get_model_points(init_time=None, fhours=None, data_name=None, var_name=None, levels=None, points={})</code></pre>
<p><font size="4"><b>参数说明</b></font></p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数</th>
<th style="text-align: left;">必选</th>
<th style="text-align: left;">类型</th>
<th style="text-align: left;">默认</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">init_time</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">datetime</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">起报时间</td>
</tr>
<tr>
<td style="text-align: left;">fhours</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">list</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">预报时效</td>
</tr>
<tr>
<td style="text-align: left;">data_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">模式名</td>
</tr>
<tr>
<td style="text-align: left;">var_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">要素名</td>
</tr>
<tr>
<td style="text-align: left;">points</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">dict</td>
<td style="text-align: left;">{}</td>
<td style="text-align: left;">站点信息，字典中必须包含经纬度{'lon':[], 'lat':[]}</td>
</tr>
<tr>
<td style="text-align: left;">levels</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">list</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">层次，None代表地面层</td>
</tr>
</tbody>
</table>
<table>
<thead>
<tr>
<th style="text-align: left;">返回值</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">stda</td>
<td style="text-align: left;">STDA格式数据</td>
</tr>
</tbody>
</table>
<p><font size="4"><b>调用示例</b></font></p>
<pre><code class="language-python">import datetime
from metdig.io.cassandra import get_model_points
init_time = datetime.datetime(2020, 8, 8, 8)
fhours = range(3, 60, 3)
points = {
'lon': [116.3833, ],
'lat': [39.9, ],
'id': ['测试站点名', ],
'city': ['测试城市', ],
'province': ['测试省', ],
}
data = get_model_points(init_time=init_time, fhours=fhours, data_name='ecmwf', var_name='t2m', points=points)
print(data)
print(data.attrs)</code></pre>
<p><font size="4"><b>输出信息</b></font></p>
<pre><code class="language-python"> level time dtime id ... lat province city ecmwf
0 0 2020-08-08 08:00:00 3 测试站点名 ... 39.9 测试省 测试城市 28.746859
1 0 2020-08-08 08:00:00 6 测试站点名 ... 39.9 测试省 测试城市 31.172658
2 0 2020-08-08 08:00:00 9 测试站点名 ... 39.9 测试省 测试城市 30.984080
3 0 2020-08-08 08:00:00 12 测试站点名 ... 39.9 测试省 测试城市 27.914333
4 0 2020-08-08 08:00:00 15 测试站点名 ... 39.9 测试省 测试城市 25.788624
5 0 2020-08-08 08:00:00 18 测试站点名 ... 39.9 测试省 测试城市 24.259966
6 0 2020-08-08 08:00:00 21 测试站点名 ... 39.9 测试省 测试城市 22.979905
7 0 2020-08-08 08:00:00 24 测试站点名 ... 39.9 测试省 测试城市 25.940686
8 0 2020-08-08 08:00:00 27 测试站点名 ... 39.9 测试省 测试城市 30.843843
9 0 2020-08-08 08:00:00 30 测试站点名 ... 39.9 测试省 测试城市 32.578908
10 0 2020-08-08 08:00:00 33 测试站点名 ... 39.9 测试省 测试城市 32.579182
11 0 2020-08-08 08:00:00 36 测试站点名 ... 39.9 测试省 测试城市 29.361650
12 0 2020-08-08 08:00:00 39 测试站点名 ... 39.9 测试省 测试城市 23.671145
13 0 2020-08-08 08:00:00 42 测试站点名 ... 39.9 测试省 测试城市 22.258317
14 0 2020-08-08 08:00:00 45 测试站点名 ... 39.9 测试省 测试城市 21.897452
15 0 2020-08-08 08:00:00 48 测试站点名 ... 39.9 测试省 测试城市 23.204375
16 0 2020-08-08 08:00:00 51 测试站点名 ... 39.9 测试省 测试城市 26.815685
17 0 2020-08-08 08:00:00 54 测试站点名 ... 39.9 测试省 测试城市 31.390309
18 0 2020-08-08 08:00:00 57 测试站点名 ... 39.9 测试省 测试城市 30.992519
[19 rows x 9 columns]
{'data_source': 'cassandra', 'level_type': 'surface', 'var_name': 't2m', 'var_cn_name': '2m温度', 'var_units': 'degC', 'valid_time': 0, 'data_start_columns': 8}</code></pre>
<h1>读取单层单时次观测站点数据</h1>
<p>单层单时次观测站点数据读取接口代码示例如下：</p>
<pre><code class="language-python">get_obs_stations(obs_time=None, data_name=None, var_name=None, level=None, id_selected=None, extent=None, x_percent=0, y_percent=0, is_save_other_info=False)</code></pre>
<p><font size="4"><b>参数说明</b></font></p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数</th>
<th style="text-align: left;">必选</th>
<th style="text-align: left;">类型</th>
<th style="text-align: left;">默认</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">obs_time</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">datetime</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测时间</td>
</tr>
<tr>
<td style="text-align: left;">data_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测类型</td>
</tr>
<tr>
<td style="text-align: left;">var_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">要素名</td>
</tr>
<tr>
<td style="text-align: left;">level</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">int</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">层次，如果是地面观测站则不传，如果是探空层则传层次</td>
</tr>
<tr>
<td style="text-align: left;">id_selected</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">list or item</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">站号，站号列表或单站</td>
</tr>
<tr>
<td style="text-align: left;">extent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">tuple</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">裁剪区域，如(50, 150, 0, 65)</td>
</tr>
<tr>
<td style="text-align: left;">x_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">number</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域经度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">y_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">number</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域纬度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">is_save_other_info</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">bool</td>
<td style="text-align: left;">False</td>
<td style="text-align: left;">是否保存从nmc_met_io中读取到的其它信息</td>
</tr>
</tbody>
</table>
<table>
<thead>
<tr>
<th style="text-align: left;">返回值</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">stda</td>
<td style="text-align: left;">STDA格式数据</td>
</tr>
</tbody>
</table>
<p><font size="4"><b>调用示例</b></font></p>
<pre><code class="language-python">import datetime
from metdig.io.cassandra import get_obs_stations
obs_time = datetime.datetime(2020, 9, 2, 12)
data = get_obs_stations(obs_time=obs_time, data_name='sfc_chn_hor', var_name='rain01')
print(data)
print(data.attrs)</code></pre>
<p><font size="4"><b>输出信息</b></font></p>
<pre><code class="language-python"> level time dtime id lon lat sfc_chn_hor
0 0 2020-09-02 12:00:00 0 58369 121.783302 31.049999 5.0
1 0 2020-09-02 12:00:00 0 58625 117.599998 28.416700 0.3
2 0 2020-09-02 12:00:00 0 58370 121.533302 31.233299 4.5
3 0 2020-09-02 12:00:00 0 56582 103.892799 27.747499 0.2
4 0 2020-09-02 12:00:00 0 55690 91.949997 27.983299 0.1
.. ... ... ... ... ... ... ...
57 0 2020-09-02 12:00:00 0 58362 121.444702 31.390800 6.0
58 0 2020-09-02 12:00:00 0 58365 121.199402 31.380600 0.1
59 0 2020-09-02 12:00:00 0 58366 121.492798 31.666401 0.3
60 0 2020-09-02 12:00:00 0 56958 100.467499 21.958900 0.1
61 0 2020-09-02 12:00:00 0 58367 121.433296 31.200001 1.7
[62 rows x 7 columns]
{'data_source': 'cassandra', 'level_type': '', 'var_name': 'rain01', 'var_cn_name': '1小时降水', 'var_units': 'mm', 'valid_time': 1, 'data_name': 'sfc_chn_hor', 'data_start_columns': 6}</code></pre>
<h1>读取单层多时次观测站点数据</h1>
<p>单层多时次观测站点数据读取接口代码示例如下：</p>
<pre><code class="language-python">get_obs_stations_multitime(obs_times=None, data_name=None, var_name=None, id_selected=None, extent=None, x_percent=0, y_percent=0, is_save_other_info=False)</code></pre>
<p><font size="4"><b>参数说明</b></font></p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数</th>
<th style="text-align: left;">必选</th>
<th style="text-align: left;">类型</th>
<th style="text-align: left;">默认</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">obs_times</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">list</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测时间列表</td>
</tr>
<tr>
<td style="text-align: left;">data_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测类型</td>
</tr>
<tr>
<td style="text-align: left;">var_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">要素名</td>
</tr>
<tr>
<td style="text-align: left;">id_selected</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">list or item</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">站号，站号列表或单站</td>
</tr>
<tr>
<td style="text-align: left;">extent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">tuple</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">裁剪区域，如(50, 150, 0, 65)</td>
</tr>
<tr>
<td style="text-align: left;">x_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">number</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域经度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">y_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">number</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域纬度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">is_save_other_info</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">bool</td>
<td style="text-align: left;">False</td>
<td style="text-align: left;">是否保存从nmc_met_io中读取到的其它信息</td>
</tr>
</tbody>
</table>
<table>
<thead>
<tr>
<th style="text-align: left;">返回值</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">stda</td>
<td style="text-align: left;">STDA格式数据</td>
</tr>
</tbody>
</table>
<p><font size="4"><b>调用示例</b></font></p>
<pre><code class="language-python">import datetime
from metdig.io.cassandra import get_obs_stations_multitime
init_time = datetime.datetime(2020, 9, 2, 12)
obs_times = []
for i in range(36):
obs_times.append(init_time + datetime.timedelta(hours=i))
data = get_obs_stations_multitime(obs_times=obs_times, data_name='sfc_chn_hor', var_name='rain01', id_selected=58131)
print(data)
print(data.attrs)</code></pre>
<p><font size="4"><b>输出信息</b></font></p>
<pre><code class="language-python"> level time dtime id lon lat sfc_chn_hor
0 0 2020-09-02 12:00:00 0 58131 118.220001 33.970299 0.9
1 0 2020-09-02 19:00:00 0 58131 118.220001 33.970299 4.6
2 0 2020-09-02 22:00:00 0 58131 118.220001 33.970299 0.1
3 0 2020-09-03 09:00:00 0 58131 118.220001 33.970299 0.2
{'data_source': 'cassandra', 'level_type': '', 'var_name': 'rain01', 'var_cn_name': '1小时降水', 'var_units': 'mm', 'valid_time': 1, 'data_name': 'sfc_chn_hor', 'data_start_columns': 6}</code></pre>
<h1>读取卫星观测数据</h1>
<p>卫星观测数据读取接口代码示例如下：</p>
<pre><code class="language-python">get_fy_awx(obs_time=None, data_name=None, var_name=None, channel=None, extent=None, x_percent=0, y_percent=0, isnearesttime=False)</code></pre>
<p><font size="4"><b>参数说明</b></font></p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数</th>
<th style="text-align: left;">必选</th>
<th style="text-align: left;">类型</th>
<th style="text-align: left;">默认</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">obs_time</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">datetime</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测时间列表</td>
</tr>
<tr>
<td style="text-align: left;">data_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测类型</td>
</tr>
<tr>
<td style="text-align: left;">var_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">要素名</td>
</tr>
<tr>
<td style="text-align: left;">channel</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">int or str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">卫星通道</td>
</tr>
<tr>
<td style="text-align: left;">extent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">tuple</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">裁剪区域，如(50, 150, 0, 65)</td>
</tr>
<tr>
<td style="text-align: left;">x_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">int</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域经度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">y_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">int</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域纬度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">isnearesttime</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">bool</td>
<td style="text-align: left;">False</td>
<td style="text-align: left;">如果obs_time非空，是否需要读取离obs_time最近的实况</td>
</tr>
</tbody>
</table>
<table>
<thead>
<tr>
<th style="text-align: left;">返回值</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">stda</td>
<td style="text-align: left;">STDA格式数据</td>
</tr>
</tbody>
</table>
<p><font size="4"><b>调用示例</b></font></p>
<pre><code class="language-python">import datetime
from metdig.io.cassandra import get_fy_awx
obs_time = datetime.datetime(2021, 5, 7, 4)
data = get_fy_awx(obs_time=obs_time, data_name='fy4al1', var_name='tbb', channel=9)
print(data)</code></pre>
<p><font size="4"><b>输出信息</b></font></p>
<pre><code class="language-python"><xarray.DataArray 'image' (member: 1, level: 1, time: 1, dtime: 1, lat: 1001, lon: 1751)>
array([[[[[[237.7 , 237.7 , 237.7 , ..., 230.63, 230.63, 231.41],
[237.7 , 237.7 , 237.7 , ..., 231.41, 231.41, 231.41],
[237.7 , 237.7 , 237.7 , ..., 231.41, 230.63, 230.63],
...,
[240.77, 240.77, 240.77, ..., 226.46, 232.16, 232.16],
[240.77, 240.77, 240.77, ..., 229.03, 234.34, 239.57],
[240.77, 240.77, 240.77, ..., 232.91, 235.72, 238.95]]]]]])
Coordinates:
* dtime (dtime) int32 0
* member (member) <U6 'fy4al1'
* time (time) datetime64[ns] 2021-05-07T04:00:00
* level (level) int32 9
* lat (lat) float64 15.0 15.04 15.08 15.12 ... 54.88 54.92 54.96 55.0
* lon (lon) float64 70.0 70.04 70.08 70.12 ... 139.9 139.9 140.0 140.0
Attributes:
data_source: cassandra
level_type:
var_name: tbb
var_cn_name: 亮温
var_units: kelvin
valid_time: 0</code></pre>
<h1>读取探空tlogp数据</h1>
<p>探空tlogp数据读取接口代码示例如下：</p>
<pre><code class="language-python">get_tlogp(obs_time=None, data_name=None, var_name=None, id_selected=None,
extent=None, x_percent=0, y_percent=0, is_save_other_info=False, dropna_any=True)</code></pre>
<p><font size="4"><b>参数说明</b></font></p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数</th>
<th style="text-align: left;">必选</th>
<th style="text-align: left;">类型</th>
<th style="text-align: left;">默认</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">obs_time</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">datetime</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测时间</td>
</tr>
<tr>
<td style="text-align: left;">data_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测类型</td>
</tr>
<tr>
<td style="text-align: left;">var_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">要素名</td>
</tr>
<tr>
<td style="text-align: left;">id_selected</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">list or item</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">站号，站号列表或单站</td>
</tr>
<tr>
<td style="text-align: left;">extent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">tuple</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">裁剪区域，如(50, 150, 0, 65)</td>
</tr>
<tr>
<td style="text-align: left;">x_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">int</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域经度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">y_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">int</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域纬度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">is_save_other_info</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">bool</td>
<td style="text-align: left;">False</td>
<td style="text-align: left;">是否保存从nmc_met_io中读取到的其它信息</td>
</tr>
<tr>
<td style="text-align: left;">dropna_any</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">bool</td>
<td style="text-align: left;">True</td>
<td style="text-align: left;">是否任意一列出现nan，drop一整行</td>
</tr>
</tbody>
</table>
<table>
<thead>
<tr>
<th style="text-align: left;">返回值</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">stda</td>
<td style="text-align: left;">STDA格式数据</td>
</tr>
</tbody>
</table>
<p><font size="4"><b>调用示例</b></font></p>
<pre><code class="language-python">import datetime
from metdig.io.cassandra import get_tlogp
obs_time = datetime.datetime(2021, 5, 7, 14, 6, 0)
data = get_tlogp(obs_time=obs_time, data_name='tlogp', var_name='hgt')
print(data)</code></pre>
<p><font size="4"><b>输出信息</b></font></p>
<pre><code class="language-python"></code></pre>
<h1>读取雷达回波全国拼图数据</h1>
<p>雷达回波全国拼图数据读取接口代码示例如下：</p>
<pre><code class="language-python">get_radar_mosaic(obs_time=None, data_name=None, var_name=None, extent=None, x_percent=0, y_percent=0, isnearesttime=False)</code></pre>
<p><font size="4"><b>参数说明</b></font></p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数</th>
<th style="text-align: left;">必选</th>
<th style="text-align: left;">类型</th>
<th style="text-align: left;">默认</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">obs_time</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">datetime</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测时间</td>
</tr>
<tr>
<td style="text-align: left;">data_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测类型</td>
</tr>
<tr>
<td style="text-align: left;">var_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">要素名</td>
</tr>
<tr>
<td style="text-align: left;">extent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">tuple</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">裁剪区域，如(50, 150, 0, 65)</td>
</tr>
<tr>
<td style="text-align: left;">x_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">int</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域经度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">y_percent</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">int</td>
<td style="text-align: left;">0</td>
<td style="text-align: left;">根据裁剪区域纬度方向扩充百分比</td>
</tr>
<tr>
<td style="text-align: left;">isnearesttime</td>
<td style="text-align: left;">否</td>
<td style="text-align: left;">bool</td>
<td style="text-align: left;">False</td>
<td style="text-align: left;">如果obs_time非空，是否需要读取离obs_time最近的实况</td>
</tr>
</tbody>
</table>
<table>
<thead>
<tr>
<th style="text-align: left;">返回值</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">stda</td>
<td style="text-align: left;">STDA格式数据</td>
</tr>
</tbody>
</table>
<p><font size="4"><b>调用示例</b></font></p>
<pre><code class="language-python">import datetime
from metdig.io.cassandra import get_radar_mosaic
obs_time = datetime.datetime(2021, 5, 12, 16)
data = get_radar_mosaic(obs_time=obs_time, data_name='achn', var_name='cref')
print(data)</code></pre>
<p><font size="4"><b>输出信息</b></font></p>
<pre><code class="language-python"><xarray.DataArray 'data' (member: 1, level: 1, time: 1, dtime: 1, lat: 4200, lon: 6200)>
array([[[[[[nan, nan, nan, ..., nan, nan, nan],
[nan, nan, nan, ..., nan, nan, nan],
[nan, nan, nan, ..., nan, nan, nan],
...,
[nan, nan, nan, ..., nan, nan, nan],
[nan, nan, nan, ..., nan, nan, nan],
[nan, nan, nan, ..., nan, nan, nan]]]]]], dtype=float32)
Coordinates:
* dtime (dtime) int32 0
* level (level) int32 0
* member (member) <U4 'achn'
* time (time) datetime64[ns] 2021-05-12T16:00:00
* lat (lat) float64 12.21 12.21 12.23 12.24 ... 54.16 54.17 54.19 54.2
* lon (lon) float64 73.0 73.01 73.02 73.03 ... 135.0 135.0 135.0 135.0
Attributes:
data_source: cassandra
level_type:
var_name: cref
var_cn_name: 雷达组合反射率
var_units:
valid_time: 0</code></pre>
<h1>读取时间范围内的风廓线数据</h1>
<p>时间范围内的风廓线数据读取接口代码示例如下：</p>
<pre><code class="language-python">get_wind_profiler_bytimerange(obs_st_time=None, obs_ed_time=None, data_name=None, var_name=None, id_selected=None)</code></pre>
<p><font size="4"><b>参数说明</b></font></p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数</th>
<th style="text-align: left;">必选</th>
<th style="text-align: left;">类型</th>
<th style="text-align: left;">默认</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">obs_st_time</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">datetime</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测开始时间</td>
</tr>
<tr>
<td style="text-align: left;">obs_ed_time</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">datetime</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测结束时间</td>
</tr>
<tr>
<td style="text-align: left;">data_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测类型</td>
</tr>
<tr>
<td style="text-align: left;">var_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">要素名</td>
</tr>
<tr>
<td style="text-align: left;">id_selected</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">int or str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">站号</td>
</tr>
</tbody>
</table>
<table>
<thead>
<tr>
<th style="text-align: left;">返回值</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">stda</td>
<td style="text-align: left;">STDA格式数据</td>
</tr>
</tbody>
</table>
<p><font size="4"><b>调用示例</b></font></p>
<pre><code class="language-python">import datetime
from metdig.io.cassandra import get_wind_profiler_bytimerange
obs_st_time = datetime.datetime(2021, 6, 6, 5)
obs_ed_time = datetime.datetime(2021, 6, 8, 8)
data = get_wind_profiler_bytimerange(obs_st_time, obs_ed_time, data_name='wind_profiler', var_name='wsp', id_selected=51463)
print(data)
print(data.attrs)</code></pre>
<p><font size="4"><b>输出信息</b></font></p>
<pre><code class="language-python"> level time dtime id lon lat wind_profiler
0 60 2021-06-06 05:00:00 0 51463 87.6458 43.7889 0.3
1 120 2021-06-06 05:00:00 0 51463 87.6458 43.7889 0.3
2 180 2021-06-06 05:00:00 0 51463 87.6458 43.7889 0.2
3 240 2021-06-06 05:00:00 0 51463 87.6458 43.7889 0.1
4 300 2021-06-06 05:00:00 0 51463 87.6458 43.7889 0.2
... ... ... ... ... ... ... ...
36276 7200 2021-06-08 08:00:00 0 51463 87.6458 43.7889 NaN
36277 7320 2021-06-08 08:00:00 0 51463 87.6458 43.7889 NaN
36278 7440 2021-06-08 08:00:00 0 51463 87.6458 43.7889 NaN
36279 7560 2021-06-08 08:00:00 0 51463 87.6458 43.7889 NaN
36280 7680 2021-06-08 08:00:00 0 51463 87.6458 43.7889 NaN
[36281 rows x 7 columns]
{'data_source': 'cassandra', 'level_type': '', 'var_name': 'wsp', 'var_cn_name': '风速', 'var_units': 'm/s', 'valid_time': 0, 'data_name': 'wind_profiler', 'data_start_columns': 6}</code></pre>
<h1>读取风廓线数据</h1>
<p>时间范围内的风廓线数据读取接口代码示例如下：</p>
<pre><code class="language-python">get_wind_profiler_bytime(obs_time=None, data_name=None, var_name=None, id_selected=None, isnearesttime=False)</code></pre>
<p><font size="4"><b>参数说明</b></font></p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数</th>
<th style="text-align: left;">必选</th>
<th style="text-align: left;">类型</th>
<th style="text-align: left;">默认</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">obs_time</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">datetime</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测开始时间</td>
</tr>
<tr>
<td style="text-align: left;">data_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">观测类型</td>
</tr>
<tr>
<td style="text-align: left;">var_name</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">要素名</td>
</tr>
<tr>
<td style="text-align: left;">id_selected</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">int or str</td>
<td style="text-align: left;">None</td>
<td style="text-align: left;">站号</td>
</tr>
<tr>
<td style="text-align: left;">isnearesttime</td>
<td style="text-align: left;"><font color="red">是</font></td>
<td style="text-align: left;">bool</td>
<td style="text-align: left;">False</td>
<td style="text-align: left;">如果obs_time非空，是否需要读取离obs_time最近的实况</td>
</tr>
</tbody>
</table>
<table>
<thead>
<tr>
<th style="text-align: left;">返回值</th>
<th style="text-align: left;">说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">stda</td>
<td style="text-align: left;">STDA格式数据</td>
</tr>
</tbody>
</table>
<p><font size="4"><b>调用示例</b></font></p>
<pre><code class="language-python">import datetime
from metdig.io.cassandra import get_wind_profiler_bytime
obs_time = datetime.datetime(2021, 6, 6, 5, 6, 0)
data = get_wind_profiler_bytime(obs_time=obs_time, data_name='wind_profiler', var_name='wdir', id_selected=51463)
print(data)</code></pre>
<p><font size="4"><b>输出信息</b></font></p>
<pre><code class="language-python"> level time dtime id lon lat wind_profiler
0 60 2021-06-06 05:06:00 0 51463 87.6458 43.7889 263.5
1 120 2021-06-06 05:06:00 0 51463 87.6458 43.7889 194.3
2 180 2021-06-06 05:06:00 0 51463 87.6458 43.7889 126.2
3 240 2021-06-06 05:06:00 0 51463 87.6458 43.7889 88.0
4 300 2021-06-06 05:06:00 0 51463 87.6458 43.7889 112.1
.. ... ... ... ... ... ... ...
66 7200 2021-06-06 05:06:00 0 51463 87.6458 43.7889 NaN
67 7320 2021-06-06 05:06:00 0 51463 87.6458 43.7889 NaN
68 7440 2021-06-06 05:06:00 0 51463 87.6458 43.7889 NaN
69 7560 2021-06-06 05:06:00 0 51463 87.6458 43.7889 NaN
70 7680 2021-06-06 05:06:00 0 51463 87.6458 43.7889 NaN
[71 rows x 7 columns]
{'data_source': 'cassandra', 'level_type': '', 'var_name': 'wdir', 'var_cn_name': '风向', 'var_units': 'degree', 'valid_time': 0, 'data_name': 'wind_profiler', 'data_start_columns': 6}
</code></pre>