一种让Flink可以读写Tdengine的方法
    2.
    发明公开

    公开(公告)号:CN118535624A

    公开(公告)日:2024-08-23

    申请号:CN202410539385.2

    申请日:2024-04-30

    摘要: 本发明提供一种让Flink可以读写Tdengine的方法,包括Source模块、Sink模块和公共模块,通过Source模块读取数据,并将数据发送到Flink的数据流中,通过公共模块提供数据结构转换器和Tdengine连接器,数据结构转换器对数据流中的数据进行转换处理,转换处理后的数据由Sink进行批量处理,并将批量处理后需要存储的数据存储到Tdengine中。本发明提供的让Flink可以读写Tdengine的方法能够在企业级的Flink生产环境中进行使用,其支持实时的source和sink,同时支持Table API/Flink SQL和DataStream API,checkpoint和savepoint的状态恢复,其中sink中支持upsert,并动态支持tdengine扩容缩容。

    基于样条插值法的综采工作面数字系统孪生刮板仿真方法

    公开(公告)号:CN117669232A

    公开(公告)日:2024-03-08

    申请号:CN202311698235.8

    申请日:2023-12-12

    摘要: 本发明提供一种基于样条插值法的综采工作面数字系统孪生刮板仿真方法,获取与刮板机一一对应的工作面推移数据,从端头数据开始剔除错误数据,数据被后用空数据代替,利用样条插值法计算出合适的数据来取代空数据,从而形成新的推移数据,使用卡尔曼滤波算法将新刮板推移数据进行过滤,结合地形数据计算出刮板的三维坐标,根据每个刮板的三维坐标算出每个刮板的航向角,刮板三维坐标结合地形再得出其俯仰角和横滚角,结合惯导数据校准每个刮板的三维坐标。使用常规的支架的推移行程传感器与惯导系统数据,在不额外增加传感器的基础上对刮板机位置与姿态进行模拟仿真,真正实现工作面刮板机位置与倾角的还原,进一步提高无人开采模拟仿真可靠性。

    基于矿业离线数据的数据传输方法、装置、设备及介质

    公开(公告)号:CN118631866A

    公开(公告)日:2024-09-10

    申请号:CN202410752103.7

    申请日:2024-06-12

    摘要: 本申请适用于互联网技术领域,尤其涉及一种基于矿业离线数据的数据传输方法、装置、设备及介质。该方法获取井下传感器采集矿井下的实时数据,使用预设的数据库,结合预设过滤规则,对实时数据进行过滤,得到并存储过滤数据,在接收到客户端发送的下载指令后,将过滤数据通过网络传输至客户端,客户端用于在下载完成后向井下服务端反馈下载完成指令,并将下载的过滤数据发送至云服务端进行存储和解析,在接收到客户端反馈的下载完成指令后,将存储的过滤数据删除,通过构建井下服务端、云服务端和客户端的方式,实现数据的传输和管理,能够解决现有井下公网覆盖不足导致数据无法有效传输的问题,降低了井下设备成本,提高了数据传输效率。