实时计算

摘要： 水利物联感知设备具有种类繁杂、协议海量、厂家多样的特点,给设备统一管理和运维带来了极大挑战。为此,设计研发了支持主流网络协议及水利标准报文协议的水利智能物联感知平台,有效解决了水利前端设备统一接入问题。平台采用分布式混合存储架构,实现海量物联监测数据的高效存储和利用。同时,基于业务规则和实时计算结果,平台可进行在线预警以及多设备间的预警联动响应,充分发挥了前端设备投资效益,降低了运维难度和成本。

摘要： 老旧住宅小区电梯、长期停用的电梯、发生事故的电梯、经历过自然灾害的电梯以及使用强度大频率高的电梯等电梯设备状况一般相对较差,常规的年度法定检验内容和检验方法已不能满足使用单位对此类电梯安全运行的要求,为了提高设备本体本质安全,提升检验机构的服务水平和质量,电梯安全评估检测应运而生。作为安全评估的产物,该管理软件集数据实时分析和结论评定、安全评估报告报表输出等多功能于一体,给安全评估检测活动提供了帮助。

摘要： 干熄焦烧损率实时计算对降低焦炭烧损的指导作用十分重大,目前只有碳平衡法、热平衡法和人工智能法三种方法可以实现。这三种方法各自从不同的角度对烧损率进行实时计算,可以相互补充、相互校验。从即时性、准确性、容错性和指导性等几个方面综合来看,人工智能实时计算方法有着明显的优势,对降低干熄焦烧损率的操作指导作用更大,值得推广使用。

摘要： 针对相移结构光中相位计算环节,提出了一种基于一维查找表的相位实时解码算法。首先根据相位计算公式中的反正切函数性质,得到四个象限之间的相位转化关系。基于得到的转换关系,使用线性函数将第一象限中的所有坐标点映射至某个离散整数区间中,结合该区间与线性函数提前建立相位的一维查找表。在相位计算过程中,首先利用相关信息计算一维查找表的索引,直接获取相位值,然后利用线性插值法与相位转换关系调整该相位值,得到最终的真实相位。通过实验验证了所提算法的有效性,与使用传统相位计算方法相比,本文提出的方法最快可提升3.97倍,使用线性插值后,相位精度可达10^(-8)。与传统的多项式逼近算法相比,该算法速度提升了1.29倍;与传统的一维查找表算法相比,该算法速度提升了1.22倍。

摘要： 2022年8月25日消息,近期持续高温天气对于用户出行,尤其是骑行、步行较多的用户来说,无疑是一大难题。近日,高德地图面向骑行和步行用户上线“防晒导航”,通过动态光影跟踪等技术,实时计算特定时段内覆盖道路的阴影面积,为用户提供更清凉的出行体验。据介绍,本次高德上线的防晒导航即是在保障原有规划合理性的基础上,通过遥感和动态光影跟踪等技术,为用户智能推荐有更多道路周边遮挡物阴影覆盖的路线,以达到清凉防晒的目的。

摘要： 文章提出了一个基于实时计算的高速公路“两客一危”监测及预警平台,通过使用实时计算分析引擎实现“两客一危”的实时监管,可满足当前以及后续高速公路“两客一危”车辆的监管要求,同时为后续车辆监管策略的制定提供理论支撑。

摘要： AR技术即增强现实技术,主要原理是实时计算摄影机影像位置及角度,并及时加入图像的一种信息化技术。如今随着信息化时代的到来,AR技术也逐渐渗透到社会各个领域,引起了大众的关注和重视。以儿童图书为例,传统纸质图书不仅成本较高,而且类型单一、不易保存,但自从AR技术应用到儿童图书领域之后,少儿科普图书、益智游戏图书、手工虚拟教学图书等类型逐渐多元化,受到了儿童的广泛喜爱。同时还发现音频、视频、互动类图书在市场上仍然较少,种类也较为单一,由此可看出,该技术在图书领域的应用虽尚未成熟,但具体在儿童图书应用中还存在较大的开发空间。

摘要： 针对低压台区复杂的现场情况,通过研究分析影响台区线损率的因素,实时准确的分析线损率变化的原因,便于对台区线损进行个性化细化管理,更加准确的定位问题台区。本文致力于进一步推动台区线损管理由结果管理向过程管理转变,提高低压台区线损管理水平和工作质量,从硬件、软件、服务三个方面提出了改善低压台区线损治理问题的方法。通过加装智能硬件设备可提供数据支撑,识别台户关系,实现分时、分段、分支、分相的线损计算,定位高损、负损台区具体位置。基于业务规则判断台区线损是否异常,利用智能用电大数据及数据挖掘分析技术对台区线损异常进行智能诊断分析,生成智能诊断分析报告,为线损异常问题整改提供咨询支撑,辅助现场人员做分析决策。另外在提升系统运行效率的同时也保障系统的业务扩展性与灵活性,增加实时计算功能的同时对现有的集中式关系型数据库进行分布式化改造。在国网某省级电力公司用电信息采集系统优化升级改造项目中的工程应用,对提升线损异常智能化、精益化的管控能力取得了很好的成效。

摘要： 在高速列车运行过程中,运行环境变化将对ATO提出更高的计算要求,ATO既要满足实时计算又要满足运行操纵多目标优化.针对该问题提出一种改进MH算法计算列车运行操纵序列.在原有MH算法基础上,对算法计算频率与寻优目标函数进行改进,提出随机惯性权重粒子群算法与司机驾驶逻辑相结合的方式计算运行操纵序列,通过选取合理的计算间隔时间使得算法性能最佳.以武广高铁85 km线路仿真高铁自动驾驶,改进MH算法中随机惯性权重粒子群算法的收敛速度优于原算法.仿真结果表明:改进MH算法在列车运行准点性和停车精度方面得到提升,为ATO在线计算提供思路.

摘要： 面向数字化转型需求,海通证券通过持续深耕大数据创新应用,深入探索基于大数据实时计算技术的日志数据分析解决方案,日前成功上线了基于Kappa架构的实时日志分析平台,并借此打造了行业领先的日志分析与监控能力.结合上述实践,本文重点介绍了海通证券实时日志分析平台在功能设计、架构设计、重要组成模块及核心技术等方面的优势与特点.

摘要： 随着物联网的蓬勃发展,中国联通M2M物联网平台承载的设备日益增多,系统性能要求也越来越高.现有系统框架采用传统软件架构,在应对高并发、大数据的场景时变得力不从心.因此,提出了以Storm流式计算引擎为基础的用量实时计算架构,以满足系统功能和性能需要.

摘要： 本文介绍移动广告中的实时计算，包括Mini batch、Hive Join，小时级统计延迟2小时，Logtailer，耦合严重/难以维护。

摘要： 简述了美团数据仓库，业务场景多，业务变化快，数据量大，介绍了实时计算技术，分析了数据处理平台架构，以及实时计算平台架构，探讨了一体化解决方案，测试开发平台化。

摘要： 本文将图像处理技术应用于增雨作业目标云的自动识别中,设计并实现了人工增雨指令实时计算软件.解析雷达产品数据,将雷达产品作为极坐标表示的图像像素的集合;利用四川盆地地区适宜增雨作业云系的雷达回波特征统计分析结果,通过区域分割、区域标记等图像处理方法识别出作业目标云,确定作业目标位置;结合作业点的地面位置和作业工具,科学计算出具有作业条件的作业点和作业指令的相关参数,极大地提高了人影作业指挥的自动化程度.

摘要： 本文重点介绍了腾讯实时计算概况，Oceanus平台，开源特性增强，流计算业务实践。提供完善的上下游数据生态，形成从接入、处理，到应用的数据闭环。借助平台的应用调试、丰富的实时指标数据、配置化告警等功能，实现监控、运维自助化。不仅通过平台Web页面可轻松查看指标、打点日志等数据，同时对调试结果应用输出等都提供了可视化的方式。结合业务实践，持续优化既有能力，并且迭代新功能;在满足自身客户需求的同时适时回馈社区。

摘要： 滴滴流计算服务体系独立部署，避免离线任务干扰,和Kafka/DDMQ同机房部署，延时低,按照YARN队列分配资源和计费,通过Router实现跨机房部署,集群物理隔离，但逻辑视图统一,机房间断网影响提交，但不影响任务运行.

摘要： 实时计算是低延时的流式数据处理，是离线计算的补充。是业务发展和技术进步的必然需求，它的关键点是分布式流式数据和低延迟。

摘要： 大数据架构部负责滴滴大数据实时和离线计算平台基础设施，存储和计算引擎的版本开发,升级和维护(hadoop/hive/spark/flink/druid/hbase/phoenix/Alluxio），离线&实时平台集群的开发,管理,维护,调优,升级，提供离线&实时开发平台,调度系统,管理平台和数据分析平台，服务所有滴滴对内数据业务，两位开源社区PMC,Committer和若干Contributor,分别参与Yarn,HDFS,Druid,Spark,Alluxio的社区贡献.

摘要： 基于车路协同技术综合感知汽车的行驶安全状态,提出了一种汽车防撞预警系统的设计方案,并对系统的物理框架和逻辑框架进行了设计.系统基于车载传感设备、路侧设备和短程通信技术获取驾驶人操作状态、车辆运行状态信息和道路交通环境信息.基于车间安全距离模型实时计算自车与相邻障碍物间的动态安全距离阈值,通过对比安全阈值和实际车间距离判断行车安全状态,检测汽车的碰撞危险并通过车载预警终端对驾驶人报警.本文提出的设计方案实现了行车安全相关信息的获取、识别和处理,准确检测行车过程中的碰撞危险,并提供及时的预警信息.

摘要： 随着以传感数据为基础的物联网应用的发展,如何在大规模历史数据基础上实现针对高速数据流的实时计算成为云计算领域的新挑战.提出了一种面向大规模历史数据的数据流处理模型RTMR,通过历史数据预处理和中间结果缓存避免每次数据流到达时的重复处理开销,利用流水化和本地化技术减少Map与Reduce阶段间的同步开销和工作节点间的数据传输开销,改进了批处理方式MapReduce方法的数据流处理能力.在此基础上,提出了一种基于模型分析的适应性RTMR集群构造算法,根据应用特征和集群环境配置节点类型、数量和拓扑结构.以城市车辆运行数据处理应用为基准测试的实验表明,上述方法能够保障大规模历史数据上数据流处理的实时性和伸缩性.

摘要： 说明一个实施由一个实时操作系统控制的计算机系统的方法，该计算机系统处理中断信号。在中断信号出现时，计算机系统中断一个正在处理的程序。封锁接收另外的中断信号并调用一个属于该中断信号的中断子例程。在处理这个中断子例程时，临时存储中断信号出现时被中断的程序的程序参量的第一部分，并且在一个中断存储器中至少存储一个关于中断信号的数据。从该中断子例程向一个中断管理子例程(IVR)分支，其中在处理IVR时重新开放接收其它的中断信号。

摘要： 说明一个实施由一个实时操作系统控制的计算机系统的方法，该计算机系统处理中断信号。在中断信号出现时，计算机系统中断一个正在处理的程序。封锁接收另外的中断信号并调用一个属于该中断信号的中断子例程。在处理这个中断子例程时，临时存储中断信号出现时被中断的程序的程序参量的第一部分，并且在一个中断存储器中至少存储一个关于中断信号的数据。从该中断子例程向一个中断管理子例程(IVR)分支，其中在处理IVR时重新开放接收其它的中断信号。

摘要： 本发明公开了一种动态实时同步多源大表数据的增强实时计算方法，该方法包括以下步骤：搭建分布式动态表管理组件；创建分布式动态表，并通过分布式动态表来标准化多源库表的数据结构；通过实时同步技术管理分布式动态表元数据变更信息的同步更新；初始化批量导入分布式动态表数据；核对导入数据的完整性；对分布式动态表中的数据进行实时更新；对数据同步更新过程进行实时数据的同步监控；将分布式动态表中的数据通过结构化查询语言转换成实时流数据的虚拟表；将虚拟表中的数据与预先配置的流数据进行结合流计算；输出流计算结果。有益效果：解决了实时计算结合外部数据源过亿大表下的复杂业务逻辑的实时计算要求。

摘要： 本发明提供一种指标实时分析系统及指标实时计算方法，该指标实时分析系统包括：日志接入模块、实时计算引擎模块和存储模块；所述日志接入模块，用于采集并解析原始日志数据，得到解析后的日志数据作为流数据，并将所述流数据写入所述存储模块；所述实时计算引擎模块，用于从所述存储模块获取所述流数据，对所述流数据进行计算，得到指标数据，并将所述指标数据写入所述存储模块。通过上述方式，本发明能够加快数据处理的速度，保证指标计算的实时性，做到即时输出。

摘要： 本申请提供一种实时计算平台及基于实时计算平台的数据计算方法，该方法应用于包括实时计算子系统、离线计算子系统，消息子系统的实时计算平台，可包括：实时计算子系统将针对新增业务数据的实时计算得到第一业务指标数据集合推送至合并子系统；离线计算子系统将针对新增离线业务数据的离线计算得到第二业务指标数据集合推送至合并子系统；合并子系统分别将所述第一业务指标数据集合和所述第二业务指标数据集合中指标类型相同的业务指标数据合并，并基于指标类型，将各合并的业务指标数据更新至第一数据库，对所述各合并的业务指标数据进行可视化展示。因此使用本申请提供的方法，可有效地降低业务数据实时计算对内存资源的消耗，提高设备性能。

摘要： 本申请提供了一种实时计算的方法以及实时计算系统，实时计算的方法由实时计算系统执行，实时计算系统包括内存数据库、实时计算引擎以及存储数据库，方法包括：内存数据库获取定义好的数据源的结构信息、数据的加工逻辑以及数据的输出规则，并发送至实时计算引擎中；实时计算引擎根据数据源的结构信息、数据的加工逻辑以及数据的输出规则，生成实时计算任务，并运行实时计算任务得到计算结果，且将计算结果发送至存储数据库；存储数据库接收客户端发送的查询信息，并依据查询信息以及计算结果得到查询结果，查询信息包括查询请求和主键信息；存储数据库将查询结果发送至客户端。该方法无需重新再编程，满足数据的实时处理运算。

摘要： 本申请适用于互联网开发技术领域，提供一种实时计算任务的部署方法、装置及实时计算系统。其方法包括：获取用于部署实时计算任务的部署参数；按照所述部署参数对所述实时计算系统中与所述实时计算任务相关联的关系型数据库表进行逻辑解析，生成所述实时计算任务对应的运行逻辑文件；基于所述实时计算系统预设的运行框架对所述运行逻辑文件进行内容解析，生成供给所述实时计算系统运行用的系统运行语法。上述方法通过预设的关系型数据库表来实现实时计算任务的部署，方法简单且部署难度低。而且，由于部署过程无需编程，降低了对部署人员的技术要求，节省了成本。本申请还提供用于执行该实时计算任务的部署方法的电子设备及存储介质。

摘要： 本申请公开了一种实时计算任务控制方法、装置及应用其的实时计算系统，其通过在任务处理模块中设置任务控制节点，将与协调服务无关的辅助数据存储于该任务控制节点中，并由任务控制节点将辅助数据发送至中央调度模块，既可以减轻协调服务模块的存储及读写压力，又可以减少中央调度模块和任务处理节点在数据读写操作上的等待时间，进而提高实时计算系统的计算能力及响应能力，有利于系统运行大集群和大拓扑任务。另外，由于上述辅助数据与协调服务无关，故即使不通过协调服务模块进行存储，也不会影响后续步骤对这些辅助数据的应用。

摘要： 本发明公开了一种动态实时同步多源大表数据的增强实时计算方法，该方法包括以下步骤：搭建分布式动态表管理组件；创建分布式动态表，并通过分布式动态表来标准化多源库表的数据结构；通过实时同步技术管理分布式动态表元数据变更信息的同步更新；初始化批量导入分布式动态表数据；核对导入数据的完整性；对分布式动态表中的数据进行实时更新；对数据同步更新过程进行实时数据的同步监控；将分布式动态表中的数据通过结构化查询语言转换成实时流数据的虚拟表；将虚拟表中的数据与预先配置的流数据进行结合流计算；输出流计算结果。有益效果：解决了实时计算结合外部数据源过亿大表下的复杂业务逻辑的实时计算要求。

摘要： 本发明提供一种指标实时分析系统及指标实时计算方法，该指标实时分析系统包括：日志接入模块、实时计算引擎模块和存储模块；所述日志接入模块，用于采集并解析原始日志数据，得到解析后的日志数据作为流数据，并将所述流数据写入所述存储模块；所述实时计算引擎模块，用于从所述存储模块获取所述流数据，对所述流数据进行计算，得到指标数据，并将所述指标数据写入所述存储模块。通过上述方式，本发明能够加快数据处理的速度，保证指标计算的实时性，做到即时输出。