Storm

摘要： During the Two Sessions this year,the Government Work Report(thereinafter the Report)pointed out the goal to encourage development of the digital economy.From growth to creating new advantages,to promoting development and improving governance,the digital economy is accelerating China’s economic development.In this regard,Kitty Fok,President of IDC China,said:“In the past three years,all enterprises have experienced unprecedented storms,and digital transformation is no longer an option,but an inevitable development of enterprises.The digital transformation spurred on by the pandemic has gone from digital adaptation in 2020 to digital acceleration and digital resilience in 2021,and then to digital priority in 2022.The 2022 Report on the Work of the Government clearly emphasizes the need to promote the development of the digital economy and strengthen the overall layout of China’s digital construction.Both industry users and ICT solution providers should have a deep understanding of the report of the Two Sessions,and constantly update and improve their strategies in the tide of digital priority.”

摘要： China’s 2022 government work report sets the growth target for the coming year at 5.5 percent, a modest growth for China compared with last year’s 8.1 percent, but not a bad prediction considering the stormy weather awaiting the world in the course of this year.

摘要： Fulminant myocarditis(FM)is an uncommon syndrome characterized by sudden and severe hemodynamic compromise secondary to acute myocardial inflammation,often presenting as profound cardiogenic shock,life-threatening ventricular arrhythmias and/or electrical storm.FM may be refractory to conventional therapies and require mechanical circulatory support(MCS).The immune system has been recognized as playing a pivotal role in the pathophysiology of myocarditis,leading to an increased focus on immunosuppressive treatment strategies.Recent data have highlighted not only the fact that FM has significantly worse outcomes than non-FM,but that prognosis and management strategies of FM are heavily dependent on histological subtype,placing greater emphasis on the role of endomyocardial biopsy in diagnosis.The impact of subtype on severity and prognosis will likewise influence how aggressively the myocarditis is managed,including whether MCS is warranted.Many patients with refractory cardiogenic shock secondary to FM end up requiring MCS,with venoarterial extracorporeal membrane oxygenation demonstrating favorable survival rates,particularly when initiated prior to the development of multiorgan failure.Among the challenges facing the field are the need to more precisely identify immunopathophysiological pathways in order to develop targeted therapies,and the need to better optimize the timing and management of MCS to minimize complications and maximize outcomes.

摘要： About twenty years ago, I was on a very long flight, during which a voice from the speaker said, “We won’t 1 drinks or the meal because we are facing a storm ahead. Please make your seat belts fastened.” Many passengers became 2, talking about it with each other. At once it became 3 in the plane.Soon, lightening lit up the darkening skies, and within moments the 4 was like a boat on waves in the storm.

摘要： The only difference between a hurricane and a typhoon is the 1 where the storm occurs.Hurricanes and typhoons are the same weather phenomenon: tropical 1)cyclones. A tropical cyclone is a generic term used by meteorologists to describe a rotating, organized system of clouds and thunderstorms that 2)originates over tropical or subtropical waters and has closed, 2 circulation.

摘要： 随着局部放电数据增多,为了提高放电数据的参数提取和模式构造的效率,将放电数据参数分析与Storm相结合,设计并使用Storm平台下双阈值过滤参数提取算法。该算法在框架组件中分别对各个阶段进行编程实现,通过数据流连通,将其产生的任务提交至集群完成,有效提取基本参数并且绘制图谱。实验结果表明,该算法与Storm框架结合具有低延迟和高吞吐量,能够提高处理效率。

摘要： The article“Correlation Structures between Satellite All-Sky Infrared Brightness Temperatures and the Atmospheric State at Storm Scales”,written by Yunji ZHANG,Eugene E.CLOTHIAUX,and David J.STENSRUD was originally pub-lished electronically on the publisher’s internet portal on 30 of April 2021 without open access.With the author(s)’decision to opt for Open Choice,the copyright of the article changed on 26 of October 2021 to©The Author(s),2021 and the article is forthwith distributed under a Creative Commons Attribution 4.0 International License,which permits use,sharing,adapta-tion,distribution and reproduction in any medium or format,as long as you give appropriate credit to the original author(s)and the source,provide a link to the Creative Commons licence,and indicate if changes were made.The images or other third party material in this article are included in the article’s Creative Commons licence,unless indicated otherwise in a credit line to the material.If material is not included in the article’s Creative Commons licence and your intended use is not permitted by statutory regulation or exceeds the permitted use,you will need to obtain permission directly from the copyright holder.To view a copy of this licence,visit http://creativecommons.org/licenses/by/4.0.The original article has been corrected.

摘要： Sri Lanka is suffering its worst economic crisis since its independence in 1948.The ongoing crisis has resulted in collapse of the currency,rising inflation,and a severe shortage of essentials,which have led to an eruption of street protests and strikes in many parts of the country.The domestic situation has been tense.On July 5,Prime Minister Ranil Wickremesinghe said in Parliament that Sri Lanka had“gone bankrupt.”On July 9,demonstrators stormed the presidential palace.

摘要： 作为目前主流的大数据流式计算平台之一,Storm在设计之初以性能为目的进行研究而忽视了高能耗的问题,但是其高能耗问题已经开始制约着平台的发展.针对这一问题,分别建立了任务分配模型、拓扑信息监控模型、数据恢复模型以及能耗模型,并进一步提出了基于Storm平台的数据恢复节能策略(energy-efficient strategy based on data recovery in Storm,DR-Storm),包括吞吐量检测算法与数据恢复算法.其中吞吐量检测算法根据拓扑信息监控模型反馈的拓扑信息计算集群吞吐量,并通过信息反馈判断是否终止整个集群内拓扑的任务.数据恢复算法根据数据恢复模型选择备份节点用于数据存储,并通过拓扑信息监控模型反馈的信息判断集群拓扑是否进行数据恢复.此外,DR-Storm通过备份节点内存恢复集群拓扑内的数据,并根据大数据流式计算的系统延迟与能效评估DR-Storm.实验结果表明:与现有研究成果相比,DR-Storm在减少系统计算延迟、降低集群功率的同时,有效节约了能耗.

摘要： 随着水土保持预防监督体系和监测网络的不断完善,各地水土保持部门积累了大量的水土流失原始信息。如何结合水土保持的历史数据和实时数据,及时掌握土壤侵蚀的变化情况是迫切需要解决的问题。为此,本文以铜仁市木寨河小江流域为例,提出一种基于Hadoop和Storm技术融合的大数据监测系统解决方案。

摘要： 本发明公开了一种基于Storm的流数据异常检测方法，包括四个步骤：数据预处理；构建初始探测模型；利用探测模型对实时数据进行异常评价；根据特定条件在线更新探测模型。本发明实施例提供的技术方案，利用Storm流式处理框架，结合孤立森林算法进行异常检测，并通过消息中间件Kafka提高算法在流数据高吞吐量下的容忍度，有效解决了大数据环境下无法实时高效地对流数据进行异常检测的问题。

摘要： 本申请涉及一种基于STORM流式计算的数据处理方法和数据处理系统。所述方法包括：STORM输入节点向STORM目标工作节点发送状态数据备份指令；STORM目标工作节点接收到状态数据备份指令时，对STORM目标工作节点的节点状态数据进行备份存储；当STORM流式计算中断时，STORM输入节点恢复STORM输入节点中最后一次备份的消息偏移量状态数据，并向STORM目标工作节点发送恢复状态数据指令；STORM目标工作节点接收到恢复状态数据指令时，从备份存储中恢复STORM目标工作节点的节点状态数据；其中，消息偏移量状态数据以及节点状态数据均用于STORM流式计算。上述方法能够在数据处理系统执行流式计算时进行数据流恢复，解决数据处理系统中STORM流式计算过程的数据丢失问题。

摘要： 本发明公开了一种基于Storm的电厂生产设备故障预警方法及系统，属于电厂设备监测领域，包括：实时采集测点数据并按主题存储到分布式消息队列中；按照主题从分布式消息队列中拉取测点数据进行过滤和验证，实时存储到HBase中，同时，将同时被采集、主题相同且相互关联的每一组测点数据分别作为一个预测目标向量；对于每一个预测目标向量Tj，利用对应的预测模型获得K个聚类，若至少存在一个聚类，其类均值与预测目标向量Tj在各维度的差值均在预警范围内，则判定正常；否则，获得类权重最大的聚类，获得不在预警范围内的差值所对应的测点并判定为异常测点，生成预警信息并存储到数据库中。本发明能够提高电厂生产设备故障预警的适应性、实时性以及可扩展性。

摘要： 本发明涉及大数据处理领域和能耗领域，特别涉及基于能耗感知的Storm大数据节能调度方法，包括构建改进的基于Storm计算框架的大数据计算能耗模型，并建立任务与计算资源的能耗优先顺序表；提交任务后判断在能耗模型的数据库中是否有该任务相关信息，若有则按照数据库中的能耗优先级为低能耗的进程分配任务；否则将该任务分配到集群中各个节点的各个上；监控每个进程上的能耗信息并写入能耗模型的数据库，根据能耗模型评判该任务的优先级，并更新优先级列表，重新提交该任务；本发明的调度策略算法能够提高大数据程序的运行能效，同时满足服务等级协议并可通过提高数据中心大数据计算的能效将会显著地降低整个数据中心的成本。

摘要： 本发明公开了一种面向Storm的多粒度可视化监控组件及监控方法，所述的监控方法包括：数据采集器从Storm集群中获取拓扑组件的状态信息后，在基本信息数据库中创建基本信息数据库表，并在所述基本信息数据库表中写入基本监控信息；数据处理器获取用户设定的监控粒度数据后，根据拓扑中的节点信息动态地创建监控信息数据表，并计算监控数据，将所述监控数据写入监控信息数据库表中；据显示器读取所述监控信息数据库中的数据，并且实时显示读取的数据。

摘要： 本发明公开了一种基于storm的铁路地质灾害监测大数据预处理方法及系统，包括：基于开源流计算storm框架为每个监测点的每个传感器数据提供并行的子计算模块，在每个子计算模块中实现铁路地质灾害监测大数据ETL处理，实现对不同监测点的多种传感器数据的实时并行预处理，有效提高数据处理效率、提高数据清洗质量；有效解决传统方法串行处理执行效率不高、不能满足监测大数据的处理需求的问题，能够满足铁路地质灾害监测数据预处理的实时性、时效性、高精度等要求，适用于复杂铁路地质灾害监测大数据实时分析与预警应用场景；同时，本发明所提供的基于storm的ELT处理方法同样也适用于其它存在多个工程监测点、多种监测数据的复杂工程。

摘要： 本发明涉及一种基于布谷鸟搜索算法的storm集群动态负载均衡方法，首先根据实时检测到的节点信息计算节点负载，然后根据负载信息为集群的节点赋予性能权值，通过布谷鸟搜索算法的寻优过程动态调整权值，最后计算出节点上任务的分配权重，根据权重分配任务，从而完成集群的动态负载均衡。本发明兼顾了集群的CPU、内存、网络等资源的实时利用情况，并实现了集群节点性能权重向量的寻优过程，完成任务的动态分配；通过对布谷鸟搜索中步长因子的自适应调整使得寻优过程能更快速的找到全局最优的权重向量，可以实现资源的合理分配，从而减小集群响应时间，具有更高的集群吞吐量和更小的系统延迟。

摘要： 本发明公开了基于storm的通用窗口框架系统，包括窗口组件、窗口调度器、事件追踪器、事件集合；窗口组件内包括窗口存储层的数据集合；窗口调度器负责窗口任务的注册，进行窗口的调度及窗口的生命周期的管理；事件集合为窗口的所有原始数据；事件追踪器负责窗口的算子的触发，窗口的算子为窗口调用的事件，事件分为四个阶段，STOP事件、NEW事件、PROCESS事件和EXPIRE事件；从而本发明提供了节约资源、快速调度的基于storm的通用窗口框架系统。

摘要： 本发明公开了一种基于storm平台的电网电力设备在线并行诊断方法及系统，目的是为了实现电力行业多元数据的监测诊断，应对电力系统的实时处理需求。其包括：根据历史电网数据自适应配置storm平台中各个组件的并行度和相关进程数；将实时电网数据接入到storm平台的Spout源组件中，形成待处理数据流；按照时间顺序将待处理数据流封装到多个Tuple元组中；利用PreBolt组件通过标准分数法对Tuple元组中的数据集进行预处理，得到标准化样本；利用训练好的故障诊断模型处理标准化样本，获得电力设备的故障诊断结果。本发明既能够满足电网监测的实时性要求，又可以提高电网数据流分类准确率和效率。

摘要： 本发明公开了一种storm任务管理和调度方法，内置预先定义好的专门消费kafka的spout和不同类型的bolt，只需对bolt添加业务处理逻辑即可，同时通过web页面拖拉拽和节点连线完成拓扑设计和参数配置，通过改造的dolphinscheduler作为调度服务进行storm任务提交，使用flume采集日志文件和rabbitmq发布订阅storm日志实时消息。本发明提供的一种storm任务管理和调度方法，提升了开发效率，任务运行稳定实现了查看功能，方便了调试。