摘要：【中文】本发明提供一种Flume系统的数据处理、传输方法及装置，其中，该数据处理方法应用于Channel端，包括：在接收到存入源数据的触发命令时，将从源Source端发来的源数据写入本地磁盘；在接收到读取源数据的触发命令时，以Sendfile零拷贝技术，从所述本地磁盘读取源数据发送到Sink端。上述提高Flume系统的容错率和性能，保证了数据高效可靠地传输，进而提高了系统的稳定性和安全性，同时降低了系统维护的成本。 【EN】The invention provides a method and a device for processing and transmitting data of a Flume system, wherein the method for processing the data is applied to a Channel end and comprises the following steps: when a trigger command for storing Source data is received, writing the Source data sent from a Source end into a local disk; and when a trigger command for reading the source data is received, reading the source data from the local disk and sending the source data to the Sink terminal by using a Sendfile zero copy technology. The error tolerance rate and the performance of the flash system are improved, the data are transmitted efficiently and reliably, the stability and the safety of the system are improved, and the maintenance cost of the system is reduced.

摘要：【中文】本发明公开了一种任务资源动态分配方法及系统，其中，该方法包括：构建历史任务信息矩阵及对应的历史任务资源分配矩阵；预设待分配任务的任务信息矩阵及任务资源分配矩阵；计算待分配任务的任务信息矩阵与任务类型为正常的历史任务信息矩阵的相似性；对相似性矩阵进行归一化处理，构建权重值矩阵；对待分配任务的任务资源分配矩阵中每个待分配的资源特征进行取值；利用取值后的任务资源分配矩阵进行任务资源分配。该方法及系统可以在新任务提交时实现合理的内存、CPU等资源分配，优化资源的利用率，避免浪费，有效提升任务查询的稳定性和查询的并发度；并且可以使任务执行时具有合理的并行度，避免过多的小文件对集群性能的影响。 【EN】The invention discloses a method and a system for dynamically allocating task resources, wherein the method comprises the following steps: constructing a historical task information matrix and a corresponding historical task resource allocation matrix; presetting a task information matrix and a task resource allocation matrix of a task to be allocated; calculating the similarity between a task information matrix of a task to be distributed and a historical task information matrix with a normal task type; carrying out normalization processing on the similarity matrix to construct a weight value matrix; taking values of each resource characteristic to be allocated in a task resource allocation matrix of the task to be allocated; and performing task resource allocation by using the valued task resource allocation matrix. The method and the system can realize reasonable resource distribution of the memory, the CPU and the like when a new task is submitted, optimize the utilization rate of the resources, avoid waste and effectively improve the stability of task query and the concurrency of the query; and the method can ensure that the task has reasonable parallelism during execution and avoid the influence of excessive small files on the cluster performance.

摘要：【中文】本发明公开了一种固网群障信息告警方法、装置及系统，该系统包括：IP网管系统、网络服保系统、光纤宽带系统和群障信息数据库；网络服保系统，用于录入的群障信息，发送至群障信息数据库；光纤宽带系统，用于检测用户设备是否存在网络故障，基于群障信息数据库，判断是否已发出群障告警，在未发出群障告警且满足预设群障发布条件的情况下，发出群障告警信息，并共享至IP网管系统；IP网管系统，用于检测网络设备是否存在网络故障，并根据光纤宽带系统发送的群障信息，判断是否已发出群障告警，并未发出群障告警的情况下，发出群障告警信息，并同步至群障信息数据库。本发明通过构建全面的群障信息数据库，能够大大提高群障告警的拦截率。 【EN】The invention discloses a method, a device and a system for alarming fixed network group fault information, wherein the system comprises the following steps: the system comprises an IP network management system, a network service protection system, an optical fiber broadband system and a group fault information database; the network service protection system is used for inputting group fault information and sending the group fault information to the group fault information database; the system comprises an optical fiber broadband system, an IP network management system and a group fault notification system, wherein the optical fiber broadband system is used for detecting whether network faults exist in user equipment, judging whether a group fault alarm is sent out or not based on a group fault information database, sending out group fault alarm information under the condition that the group fault alarm is not sent out and preset group fault release conditions are met, and sharing the group fault alarm information to the IP network management system; and the IP network management system is used for detecting whether the network equipment has network faults or not, judging whether a group fault alarm is sent or not according to the group fault information sent by the optical fiber broadband system, sending out the group fault alarm information under the condition that the group fault alarm is not sent out, and synchronizing the group fault alarm information to the group fault information database. According to the invention, by constructing a comprehensive group fault information database, the interception rate of group fault alarm can be greatly improved.

摘要：【中文】本发明提供了一种物联网MME网元信令追踪方法及装置，该方法包括：获取目标终端的标识；根据目标终端的标识，查询HSS上的EPS动态信息，确定目标终端对应的MME网元，所述HSS与MME网元进行通信；对目标终端对应的MME网元进行追踪，获得MME网元的原始信令追踪数据；解析MME网元的原始信令追踪数据，获得MME网元的解析信令信息。本发明可以追踪物联网网元MME信令，效率高。 【EN】The invention provides a method and a device for tracing an Internet of things MME network element signaling, wherein the method comprises the following steps: acquiring an identifier of a target terminal; inquiring EPS dynamic information on an HSS according to the identification of the target terminal, and determining an MME network element corresponding to the target terminal, wherein the HSS is communicated with the MME network element; tracking an MME (mobility management entity) network element corresponding to a target terminal to obtain original signaling tracking data of the MME network element; analyzing the original signaling tracking data of the MME network element to obtain the analyzed signaling information of the MME network element. The invention can track the signaling of the MME of the network element of the Internet of things and has high efficiency.

摘要：【中文】本发明实施例提供了一种数据库日志同步方法、装置、计算机设备及可读存储介质，其中，该方法包括：通过伪从节点同步服务模拟MySQL的从节点，从MySQL中抽取binlog日志；通过所述伪从节点同步服务将抽取的binlog日志存储在所述处理引擎的存储模块中；通过解析服务从存储模块中读取binlog日志并解析，将解析结果保存至目标存储中。该方案使得整个MySQL的binlog日志同步过程都可以在处理引擎中通过程序完成，避免引入第三方同步工具、消息队列或JMQ等中间件等额外的组件，同时在MySQL的binlog日志同步过程中可以避免多方组件配合，有利于简化处理流程。 【EN】The embodiment of the invention provides a database log synchronization method, a database log synchronization device, computer equipment and a readable storage medium, wherein the method comprises the following steps: simulating slave nodes of MySQL by pseudo slave node synchronization service, and extracting binlog logs from the MySQL; storing, by the pseudo slave node synchronization service, the extracted binlog log in a storage module of the processing engine; and reading and analyzing the binlog log from the storage module through the analysis service, and storing an analysis result into a target storage. The scheme ensures that the whole binlog log synchronization process of MySQL can be completed in the processing engine through programs, avoids introducing additional components such as third-party synchronization tools, message queues or middleware such as JMQ and the like, and simultaneously can avoid the cooperation of multiple components in the binlog log synchronization process of MySQL, thereby being beneficial to simplifying the processing flow.

摘要：【中文】本发明提供了一种PON网络故障监控方法及装置，该方法包括：获取PON网络的端口脱网信息；端口脱网信息包括脱网端口类型；确定端口脱网信息的对端设备类型；若对端设备类型为目标设备，根据脱网端口类型生成目标设备的告警信息。本发明可以根据端口脱网信息和端口类型自动生成PON网络中目标设备的告警信息，通过及时对故障进行排查，提升故障排查效率，也提升了网络的运营效率。 【EN】The invention provides a PON (passive optical network) network fault monitoring method and a PON network fault monitoring device, wherein the method comprises the following steps: acquiring port offline information of a PON (passive optical network); the port offline information comprises an offline port type; determining the opposite terminal equipment type of the port offline information; and if the opposite terminal equipment type is the target equipment, generating alarm information of the target equipment according to the off-line port type. The invention can automatically generate the alarm information of the target equipment in the PON network according to the port offline information and the port type, and improves the troubleshooting efficiency and the operation efficiency of the network by troubleshooting faults in time.

摘要：【中文】本发明提供了一种M设备上线配置方法及装置，其中该方法包括：获取M设备待安装地址；根据待安装地址，在地图上打点，确定最优接入机房；根据最优接入机房匹配上联ipran设备和接入端口，对上联ipran设备和接入端口进行资源预占；对上联ipran设备进行预上线配置；基于上联ipran设备的预上线配置，对M设备进行上线配置。该方法通过在安装M设备前确定最优可接入的机房，减少了安装人员的工作量，减少了安装成本，提高了安装效率，减少重复施工或安装错误的可能性。 【EN】The invention provides an M device online configuration method and a device, wherein the method comprises the following steps: acquiring an address to be installed of the M equipment; dotting on a map according to the address to be installed, and determining the optimal access machine room; matching the upper connecting ipran equipment and the access port according to the optimal access machine room, and performing resource pre-occupation on the upper connecting ipran equipment and the access port; pre-online configuration is carried out on the upper connecting ipran equipment; and performing online configuration on the M equipment based on the pre-online configuration of the upper connecting ipran equipment. According to the method, the optimal accessible machine room is determined before the M equipment is installed, so that the workload of installation personnel is reduced, the installation cost is reduced, the installation efficiency is improved, and the possibility of repeated construction or installation errors is reduced.

摘要：【中文】本发明公开了一种流量处理框架建立方法及装置，其中方法包括：获取流量产品参数，客户场景参数和应用需求参数；根据所述流量产品参数，客户场景参数和应用需求参数，选取至少一种网卡类型和至少一种核类型，其中所述网卡类型包括：接收网卡和发送网卡，所述核类型包括：接收核，处理核和发送核；根据选取的网卡类型、核类型和预设连接关系数据，建立流量处理框架。本发明可以有效降低开发成本，提高适应新业务拓展的能力。 【EN】The invention discloses a method and a device for establishing a flow processing framework, wherein the method comprises the following steps: acquiring flow product parameters, client scene parameters and application demand parameters; selecting at least one network card type and at least one core type according to the flow product parameters, the client scene parameters and the application demand parameters, wherein the network card type comprises the following steps: receiving a network card and sending the network card, wherein the core types comprise: a receiving core, a processing core and a sending core; and establishing a flow processing frame according to the selected network card type, the core type and the preset connection relation data. The invention can effectively reduce the development cost and improve the capability of adapting to the expansion of new services.

摘要：【中文】本申请公开了一种诊断Elasticsearch集群问题的方法及装置，该方法包括：接收用户输入的诊断参数；根据诊断参数，从封装的所有用于诊断Elasticsearch集群问题的应用程序编程接口API中确定目标API，所述API用于获取对应的诊断项的信息；通过所述目标API获取对应的目标诊断项的信息；根据所述目标诊断项的信息判断目标诊断项是否出现问题；如果目标诊断项出现问题，则通过与问题关联的目标诊断项中诊断子项对应的API查询子项信息；根据所述子项信息，确定目标诊断项出现问题的原因。本申请可以节约诊断Elasticsearch集群问题的时间。 【EN】The application discloses a method and a device for diagnosing Elasticissearch cluster problems, wherein the method comprises the following steps: receiving diagnosis parameters input by a user; according to the diagnosis parameters, determining a target API from all packaged Application Programming Interfaces (APIs) for diagnosing the Elasticissearch cluster problem, wherein the API is used for acquiring information of corresponding diagnosis items; acquiring information of a corresponding target diagnosis item through the target API; judging whether the target diagnosis item has a problem or not according to the information of the target diagnosis item; if the target diagnosis item has a problem, inquiring sub-item information through an API corresponding to a diagnosis sub-item in the target diagnosis item associated with the problem; and determining the reason of the problem of the target diagnosis item according to the sub-item information. The method and the device can save time for diagnosing the Elasticissearch clustering problem.

摘要：【中文】本发明公开了一种机房市电停电监测方法及装置，该方法包括：将机房市电停电监测的光网络单元的设备类型字段配置为预设字段；按照预设ping测试条件对机房市电停电监测的光网络单元进行ping测试；在ping测试不通过且ping系统日志中的设备类型字段为预设字段时，产生机房市电停电的告警。本发明无需部署动环监测，在ping测试不通过且ping系统日志中的设备类型字段为预设字段时，进而产生机房市电停电的告警，因此能够在及时确定机房市电停电的同时，降低监测成本。 【EN】The invention discloses a method and a device for monitoring commercial power outage of a machine room, wherein the method comprises the following steps: configuring a device type field of an optical network unit for monitoring the power failure of the commercial power of a machine room into a preset field; performing ping test on the optical network unit for monitoring the power failure of the commercial power of the machine room according to preset ping test conditions; and when the ping test fails and the device type field in the ping system log is a preset field, generating an alarm of the power failure of the commercial power of the machine room. According to the invention, dynamic loop monitoring is not required to be deployed, and when the ping test fails and the equipment type field in the ping system log is a preset field, the alarm of the machine room commercial power failure is generated, so that the monitoring cost can be reduced while the machine room commercial power failure is determined in time.