[go: up one dir, main page]

CN118694803A - Cloud platform system traffic dynamic balancing processing method and device - Google Patents

Cloud platform system traffic dynamic balancing processing method and device Download PDF

Info

Publication number
CN118694803A
CN118694803A CN202411159175.7A CN202411159175A CN118694803A CN 118694803 A CN118694803 A CN 118694803A CN 202411159175 A CN202411159175 A CN 202411159175A CN 118694803 A CN118694803 A CN 118694803A
Authority
CN
China
Prior art keywords
cloud platform
traffic
flow
access
user
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Granted
Application number
CN202411159175.7A
Other languages
Chinese (zh)
Other versions
CN118694803B (en
Inventor
史延莹
刘国强
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Zijincheng Credit Investigation Co ltd
Original Assignee
Zijincheng Credit Investigation Co ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Zijincheng Credit Investigation Co ltd filed Critical Zijincheng Credit Investigation Co ltd
Priority to CN202411159175.7A priority Critical patent/CN118694803B/en
Publication of CN118694803A publication Critical patent/CN118694803A/en
Application granted granted Critical
Publication of CN118694803B publication Critical patent/CN118694803B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/01Protocols
    • H04L67/1396Protocols specially adapted for monitoring users' activity
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/14Network analysis or design
    • H04L41/142Network analysis or design using statistical or mathematical methods
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00Traffic control in data switching networks
    • H04L47/70Admission control; Resource allocation
    • H04L47/83Admission control; Resource allocation based on usage prediction
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/01Protocols
    • H04L67/10Protocols in which an application is distributed across nodes in the network
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/50Network services
    • H04L67/535Tracking the activity of the user

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Physics & Mathematics (AREA)
  • Algebra (AREA)
  • General Physics & Mathematics (AREA)
  • Mathematical Analysis (AREA)
  • Mathematical Optimization (AREA)
  • Mathematical Physics (AREA)
  • Probability & Statistics with Applications (AREA)
  • Pure & Applied Mathematics (AREA)
  • Computer Hardware Design (AREA)
  • General Engineering & Computer Science (AREA)
  • Management, Administration, Business Operations System, And Electronic Commerce (AREA)

Abstract

The application provides a method and a device for dynamically balancing flow of a cloud platform system, wherein the method comprises the following steps: monitoring real-time flow data in the cloud platform system, performing time sequence model analysis on the real-time flow data in a set time period, and determining a corresponding flow change trend; performing cluster analysis on a user access mode and a user access service corresponding to the real-time flow data, determining access behavior characteristics of the user, and determining a corresponding access behavior change trend according to the access behavior characteristics and through a preset association rule mining algorithm; inputting the flow change trend and the access behavior change trend into a set decision tree regression prediction model, and dynamically adjusting the resource allocation of the cloud platform system when a flow peak or an abnormal event is detected; the application can effectively improve the flexibility and response speed of the system, optimize the resource utilization rate and ensure the stable operation of the system under the peak flow.

Description

云平台系统流量动态平衡处理方法及装置Cloud platform system traffic dynamic balancing processing method and device

技术领域Technical Field

本申请涉及数据处理领域,具体涉及一种云平台系统流量动态平衡处理方法及装置。The present application relates to the field of data processing, and specifically to a method and device for dynamically balancing traffic in a cloud platform system.

背景技术Background Art

在互联网时代,系统流量已经成为一个较难预估的指标。很多互联网公司会提前预判某个活动的流量,并提前人工增加机器,以满足高峰流量的需求。然而,流量预估经常超出预期,这种方法并不能完全解决问题。In the Internet age, system traffic has become a difficult indicator to predict. Many Internet companies will predict the traffic of a certain activity in advance and manually add machines in advance to meet the peak traffic demand. However, traffic estimates often exceed expectations, and this method cannot completely solve the problem.

当前的流量管理主要依赖于人工判断和静态配置。这种方法存在诸多局限性。首先,人工判断流量高峰往往依赖于经验和历史数据,但互联网流量的变化具有高度的不确定性和瞬时性,传统方法难以准确预测。其次,静态配置的资源在面对突发的流量高峰时,往往显得捉襟见肘,导致系统性能下降甚至崩溃。Current traffic management mainly relies on manual judgment and static configuration. This approach has many limitations. First, manual judgment of traffic peaks often relies on experience and historical data, but changes in Internet traffic are highly uncertain and instantaneous, and traditional methods are difficult to accurately predict. Second, statically configured resources are often stretched when faced with sudden traffic peaks, resulting in system performance degradation or even crashes.

在流量识别方面,现有系统多采用预设规则和固定阈值进行流量监控和预警。这种方法在面对快速变化的流量时,反应速度较慢,无法及时调整资源配置。同时,流量识别的精度也受到限制,无法准确区分正常流量和异常流量,影响了资源调度的效率和准确性。In terms of traffic identification, existing systems mostly use preset rules and fixed thresholds for traffic monitoring and early warning. This method has a slow response speed when facing rapidly changing traffic and cannot adjust resource allocation in time. At the same time, the accuracy of traffic identification is also limited, and it is impossible to accurately distinguish between normal and abnormal traffic, which affects the efficiency and accuracy of resource scheduling.

在资源扩容方面,传统系统通常需要人工干预,提前增加机器或配置资源。这不仅增加了运维成本和复杂度,还存在资源利用率低的问题。由于不能实时动态调整资源配置,系统在非高峰期往往会出现大量闲置资源,造成浪费。而在流量激增时,资源扩容的滞后性又会导致系统性能瓶颈,无法满足用户需求。In terms of resource expansion, traditional systems usually require manual intervention to add machines or configure resources in advance. This not only increases the cost and complexity of operation and maintenance, but also has the problem of low resource utilization. Since resource configuration cannot be adjusted dynamically in real time, the system often has a large number of idle resources during non-peak hours, causing waste. When traffic surges, the lag in resource expansion will lead to system performance bottlenecks and fail to meet user needs.

总的来说,现有的流量管理和资源扩容方法存在诸多不足,难以应对互联网时代瞬息万变的流量需求。通过引入动态识别流量和动态扩容服务的方法,可以有效提高系统的灵活性和响应速度,优化资源利用率,提升用户体验。然而,这也对技术和系统架构提出了更高的要求,需要在数据分析、自动化调度和系统稳定性等方面进行全面提升。In general, the existing traffic management and resource expansion methods have many shortcomings and are difficult to cope with the ever-changing traffic demands in the Internet era. By introducing methods for dynamically identifying traffic and dynamically expanding services, the flexibility and response speed of the system can be effectively improved, resource utilization can be optimized, and user experience can be improved. However, this also puts higher requirements on technology and system architecture, requiring comprehensive improvements in data analysis, automated scheduling, and system stability.

发明内容Summary of the invention

针对现有技术中的问题,本申请提供一种云平台系统流量动态平衡处理方法及装置,能够有效提高系统的灵活性和响应速度,优化资源利用率,确保系统在高峰流量下的稳定运行。In response to the problems in the prior art, the present application provides a method and device for dynamically balancing the traffic of a cloud platform system, which can effectively improve the flexibility and response speed of the system, optimize resource utilization, and ensure the stable operation of the system under peak traffic.

为了解决上述问题中的至少一个,本申请提供以下技术方案:In order to solve at least one of the above problems, the present application provides the following technical solutions:

第一方面,本申请提供一种云平台系统流量动态平衡处理方法,包括:In a first aspect, the present application provides a method for dynamically balancing traffic in a cloud platform system, comprising:

监测云平台系统中的实时流量数据,对设定时间段内的所述实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;Monitor the real-time traffic data in the cloud platform system, perform time series model analysis on the real-time traffic data within a set time period, and determine the corresponding traffic change trend;

对与所述实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,根据所述聚类分析的结果确定用户的访问行为特征,并根据所述访问行为特征和通过预设关联规则挖掘算法在用户访问数据集上确定的用户在不同业务场景下访问行为之间的相关性,确定对应的访问行为变化趋势;Performing cluster analysis on user access patterns and user access services corresponding to the real-time traffic data, determining user access behavior characteristics based on the results of the cluster analysis, and determining corresponding access behavior change trends based on the access behavior characteristics and the correlation between user access behaviors in different business scenarios determined on the user access data set by a preset association rule mining algorithm;

将所述流量变化趋势和所述访问行为变化趋势输入设定决策树回归预测模型,根据所述决策树回归预测模型的输出判断是否存在流量高峰或异常事件,当检测到所述流量高峰或异常事件时,根据所述决策树回归预测模型输出的流量变化需求动态调整所述云平台系统的资源分配,并在所述云平台系统的实时流量数据回落至正常水平后释放多余的资源直至恢复标准配置。The traffic change trend and the access behavior change trend are input into a set decision tree regression prediction model, and whether there is a traffic peak or abnormal event is determined according to the output of the decision tree regression prediction model. When the traffic peak or abnormal event is detected, the resource allocation of the cloud platform system is dynamically adjusted according to the traffic change demand output by the decision tree regression prediction model, and after the real-time traffic data of the cloud platform system drops back to a normal level, excess resources are released until the standard configuration is restored.

进一步地,所述监测云平台系统中的实时流量数据,对设定时间段内的所述实时流量数据进行时间序列模型分析,确定对应的流量变化趋势,包括:Furthermore, the real-time traffic data in the monitoring cloud platform system is analyzed by a time series model for the real-time traffic data within a set time period to determine the corresponding traffic change trend, including:

从云平台系统中实时采集用户访问流量数据,对所述用户访问流量数据进行清洗和转换, 并将所述用户访问流量数据转换为时间序列格式;Collect user access traffic data from the cloud platform system in real time, clean and convert the user access traffic data, and convert the user access traffic data into a time series format;

通过网格搜索确定ARIMA时间序列模型在转换为时间序列格式的用户访问流量数据上预测误差最小的最优参数组合,并根据所述ARIMA时间序列模型的输出确定流量变化趋势。The optimal parameter combination with the smallest prediction error of the ARIMA time series model on the user access flow data converted into a time series format is determined through grid search, and the flow change trend is determined according to the output of the ARIMA time series model.

进一步地,所述对与所述实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,根据所述聚类分析的结果确定用户的访问行为特征,包括:Furthermore, performing cluster analysis on the user access patterns and user access services corresponding to the real-time traffic data, and determining the user access behavior characteristics according to the results of the cluster analysis, includes:

获取与所述实时流量数据相对应的用户访问模式和用户访问业务;Acquire user access patterns and user access services corresponding to the real-time traffic data;

根据所述用户访问模式、所述用户访问业务以及预设K-Means聚类算法将用户划分为不同类型的群体, 确定用户的访问行为特征,其中,每个群体都有独特的访问行为特征。According to the user access mode, the user access service and the preset K-Means clustering algorithm, the users are divided into different types of groups, and the user access behavior characteristics are determined, wherein each group has a unique access behavior characteristic.

进一步地, 所述根据所述访问行为特征和通过预设关联规则挖掘算法在用户访问数据集上确定的用户在不同业务场景下访问行为之间的相关性,确定对应的访问行为变化趋势,包括:Further, the determining of the corresponding access behavior change trend according to the access behavior characteristics and the correlation between the user's access behaviors in different business scenarios determined on the user access data set by a preset association rule mining algorithm includes:

根据用户访问行为特征分析确定不同用户群体的访问行为;Determine the access behavior of different user groups based on user access behavior characteristics analysis;

利用Apriori关联规则挖掘算法在用户访问数据集上确定不同用户群体在各自业务场景下的访问行为之间的相关性,并根据所述相关性确定对应的访问行为变化趋势。The Apriori association rule mining algorithm is used to determine the correlation between the access behaviors of different user groups in their respective business scenarios on the user access data set, and the corresponding access behavior change trend is determined based on the correlation.

进一步地,所述将所述流量变化趋势和所述访问行为变化趋势输入设定决策树回归预测模型,根据所述决策树回归预测模型的输出判断是否存在流量高峰或异常事件,包括:Furthermore, the flow change trend and the access behavior change trend are input into a decision tree regression prediction model, and judging whether there is a flow peak or abnormal event according to the output of the decision tree regression prediction model, includes:

根据历史样本数据训练决策树回归预测模型直至形成最优预测规则,将所述流量变化趋势和所述访问行为变化趋势输入设定决策树回归预测模型;Training a decision tree regression prediction model according to historical sample data until an optimal prediction rule is formed, and inputting the traffic change trend and the access behavior change trend into a set decision tree regression prediction model;

根据所述决策树回归预测模型输出的预测概率数值与预设阈值的数值比较关系判断是否存在流量高峰或异常事件。The presence of a traffic peak or abnormal event is determined based on the comparison between the predicted probability value output by the decision tree regression prediction model and the value of a preset threshold.

进一步地,所述当检测到所述流量高峰或异常事件时,根据所述决策树回归预测模型输出的流量变化需求动态调整所述云平台系统的资源分配,包括:Furthermore, when the traffic peak or abnormal event is detected, the resource allocation of the cloud platform system is dynamically adjusted according to the traffic change demand output by the decision tree regression prediction model, including:

当检测到存在流量高峰或异常事件时,根据所述决策树回归预测模型的输出,确定导致异常的关键因素;When a traffic peak or an abnormal event is detected, the key factors causing the abnormality are determined according to the output of the decision tree regression prediction model;

根据决策树回归模型预测的流量变化需求和所述导致异常的关键因素动态调整云平台系统的资源分配策略。The resource allocation strategy of the cloud platform system is dynamically adjusted according to the traffic change demand predicted by the decision tree regression model and the key factors causing the anomaly.

进一步地,所述在所述云平台系统的实时流量数据回落至正常水平后释放多余的资源直至恢复标准配置,包括:Furthermore, after the real-time traffic data of the cloud platform system falls back to a normal level, the redundant resources are released until the standard configuration is restored, including:

对所述云平台系统的实时流量数据进行监测;Monitoring real-time traffic data of the cloud platform system;

在监测所述云平台系统的实时流量数据回落至正常水平后逐步缩减计算节点数量和存储空间直至系统的资源配置完全恢复到事先设定的标准状态。After monitoring the real-time traffic data of the cloud platform system and returning to normal levels, the number of computing nodes and storage space are gradually reduced until the system's resource configuration is fully restored to a pre-set standard state.

第二方面,本申请提供一种云平台系统流量动态平衡处理装置,包括:In a second aspect, the present application provides a cloud platform system flow dynamic balancing processing device, comprising:

流量变化确定模块,用于监测云平台系统中的实时流量数据,对设定时间段内的所述实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;A traffic change determination module is used to monitor the real-time traffic data in the cloud platform system, perform time series model analysis on the real-time traffic data within a set time period, and determine the corresponding traffic change trend;

访问行为确定模块,用于对与所述实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,根据所述聚类分析的结果确定用户的访问行为特征,并根据所述访问行为特征和通过预设关联规则挖掘算法在用户访问数据集上确定的用户在不同业务场景下访问行为之间的相关性,确定对应的访问行为变化趋势;An access behavior determination module, used to perform cluster analysis on user access patterns and user access services corresponding to the real-time traffic data, determine the user's access behavior characteristics according to the results of the cluster analysis, and determine the corresponding access behavior change trend according to the access behavior characteristics and the correlation between the user's access behaviors in different business scenarios determined on the user access data set by a preset association rule mining algorithm;

异常预测模块,用于将所述流量变化趋势和所述访问行为变化趋势输入设定决策树回归预测模型,根据所述决策树回归预测模型的输出判断是否存在流量高峰或异常事件,当检测到所述流量高峰或异常事件时,根据所述决策树回归预测模型输出的流量变化需求动态调整所述云平台系统的资源分配,并在所述云平台系统的实时流量数据回落至正常水平后释放多余的资源直至恢复标准配置。An abnormal prediction module is used to input the traffic change trend and the access behavior change trend into a set decision tree regression prediction model, and determine whether there is a traffic peak or abnormal event based on the output of the decision tree regression prediction model. When the traffic peak or abnormal event is detected, the resource allocation of the cloud platform system is dynamically adjusted according to the traffic change demand output by the decision tree regression prediction model, and after the real-time traffic data of the cloud platform system drops back to a normal level, excess resources are released until the standard configuration is restored.

第三方面,本申请提供一种电子设备,包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,所述处理器执行所述程序时实现所述的云平台系统流量动态平衡处理方法的步骤。In a third aspect, the present application provides an electronic device comprising a memory, a processor, and a computer program stored in the memory and executable on the processor, wherein when the processor executes the program, the steps of the cloud platform system traffic dynamic balancing processing method are implemented.

第四方面,本申请提供一种计算机可读存储介质,其上存储有计算机程序,该计算机程序被处理器执行时实现所述的云平台系统流量动态平衡处理方法的步骤。In a fourth aspect, the present application provides a computer-readable storage medium having a computer program stored thereon, which, when executed by a processor, implements the steps of the cloud platform system traffic dynamic balancing processing method.

第五方面,本申请提供一种计算机程序产品,包括计算机程序/指令,该计算机程序/指令被处理器执行时实现所述的云平台系统流量动态平衡处理方法的步骤。In a fifth aspect, the present application provides a computer program product, including a computer program/instruction, which, when executed by a processor, implements the steps of the cloud platform system traffic dynamic balancing processing method.

由上述技术方案可知,本申请提供一种云平台系统流量动态平衡处理方法及装置,通过监测云平台系统中的实时流量数据,对设定时间段内的实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;对与实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,确定用户的访问行为特征,并根据访问行为特征和通过预设关联规则挖掘算法,确定对应的访问行为变化趋势;将流量变化趋势和访问行为变化趋势输入设定决策树回归预测模型,当检测到流量高峰或异常事件时,动态调整云平台系统的资源分配,由此能够有效提高系统的灵活性和响应速度,优化资源利用率,确保系统在高峰流量下的稳定运行。It can be seen from the above technical scheme that the present application provides a method and device for dynamically balancing the flow of a cloud platform system. By monitoring the real-time flow data in the cloud platform system, a time series model analysis is performed on the real-time flow data within a set time period to determine the corresponding flow change trend; a cluster analysis is performed on the user access patterns and user access services corresponding to the real-time flow data to determine the user's access behavior characteristics, and the corresponding access behavior change trend is determined based on the access behavior characteristics and a preset association rule mining algorithm; the flow change trend and the access behavior change trend are input into a set decision tree regression prediction model, and when a flow peak or abnormal event is detected, the resource allocation of the cloud platform system is dynamically adjusted, thereby effectively improving the flexibility and response speed of the system, optimizing resource utilization, and ensuring the stable operation of the system under peak flow.

附图说明BRIEF DESCRIPTION OF THE DRAWINGS

为了更清楚地说明本申请实施例或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍,显而易见地,下面描述中的附图是本申请的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。In order to more clearly illustrate the embodiments of the present application or the technical solutions in the prior art, the drawings required for use in the embodiments or the description of the prior art will be briefly introduced below. Obviously, the drawings described below are some embodiments of the present application. For ordinary technicians in this field, other drawings can be obtained based on these drawings without paying any creative work.

图1为本申请实施例中的云平台系统流量动态平衡处理方法的流程示意图之一;FIG1 is a flow chart of a method for dynamically balancing flow in a cloud platform system according to an embodiment of the present application;

图2为本申请实施例中的云平台系统流量动态平衡处理方法的流程示意图之二;FIG2 is a second flow chart of a method for dynamically balancing flow of a cloud platform system in an embodiment of the present application;

图3为本申请实施例中的云平台系统流量动态平衡处理方法的流程示意图之三;FIG3 is a third flow chart of a method for dynamically balancing flow of a cloud platform system in an embodiment of the present application;

图4为本申请实施例中的云平台系统流量动态平衡处理方法的流程示意图之四;FIG4 is a fourth flow chart of a method for dynamically balancing flow of a cloud platform system in an embodiment of the present application;

图5为本申请实施例中的云平台系统流量动态平衡处理方法的流程示意图之五;FIG5 is a fifth flow chart of a method for dynamically balancing flow of a cloud platform system in an embodiment of the present application;

图6为本申请实施例中的云平台系统流量动态平衡处理方法的流程示意图之六;FIG6 is a sixth flow chart of a method for dynamically balancing flow of a cloud platform system in an embodiment of the present application;

图7为本申请实施例中的云平台系统流量动态平衡处理方法的流程示意图之七;FIG. 7 is a seventh flow chart of a method for dynamically balancing flow of a cloud platform system in an embodiment of the present application;

图8为本申请实施例中的云平台系统流量动态平衡处理装置的结构图;FIG8 is a structural diagram of a cloud platform system flow dynamic balancing processing device in an embodiment of the present application;

图9为本申请实施例中的电子设备的结构示意图。FIG. 9 is a schematic diagram of the structure of an electronic device in an embodiment of the present application.

附图标记:Reference numerals:

电子设备9600、中央处理器9100、通信模块9110、天线9111、输入单元9120、音频处理器9130、扬声器9131、麦克风9132、存储器9140、缓冲存储器9141、应用/功能存储部9142、数据存储部9143、驱动程序存储部9144、显示器9160、电源9170。Electronic device 9600, central processing unit 9100, communication module 9110, antenna 9111, input unit 9120, audio processor 9130, speaker 9131, microphone 9132, memory 9140, buffer memory 9141, application/function storage unit 9142, data storage unit 9143, driver program storage unit 9144, display 9160, power supply 9170.

具体实施方式DETAILED DESCRIPTION

为使本申请实施例的目的、技术方案和优点更加清楚,下面将结合本申请实施例中的附图,对本申请实施例中的技术方案进行清楚、完整的描述,显然,所描述的实施例是本申请一部分实施例,而不是全部的实施例。基于本申请中的实施例,本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例,都属于本申请保护的范围。In order to make the purpose, technical solution and advantages of the embodiments of the present application clearer, the technical solution in the embodiments of the present application will be clearly and completely described below in conjunction with the drawings in the embodiments of the present application. Obviously, the described embodiments are part of the embodiments of the present application, not all of the embodiments. Based on the embodiments in the present application, all other embodiments obtained by ordinary technicians in this field without creative work are within the scope of protection of this application.

本申请技术方案中对数据的获取、存储、使用、处理等均符合国家法律法规的相关规定。The acquisition, storage, use, and processing of data in the technical solution of this application comply with the relevant provisions of national laws and regulations.

考虑到现有技术中流量管理和资源扩容方法存在诸多不足,难以应对互联网时代瞬息万变的流量需求的问题,本申请提供一种云平台系统流量动态平衡处理方法及装置,通过监测云平台系统中的实时流量数据,对设定时间段内的实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;对与实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,确定用户的访问行为特征,并根据访问行为特征和通过预设关联规则挖掘算法,确定对应的访问行为变化趋势;将流量变化趋势和访问行为变化趋势输入设定决策树回归预测模型,当检测到流量高峰或异常事件时,动态调整云平台系统的资源分配,由此能够有效提高系统的灵活性和响应速度,优化资源利用率,确保系统在高峰流量下的稳定运行。Taking into account the many deficiencies in the traffic management and resource expansion methods in the prior art, which are difficult to cope with the problem of rapidly changing traffic demands in the Internet era, the present application provides a method and device for dynamically balancing traffic in a cloud platform system. By monitoring the real-time traffic data in the cloud platform system, a time series model analysis is performed on the real-time traffic data within a set time period to determine the corresponding traffic change trend; a cluster analysis is performed on the user access patterns and user access services corresponding to the real-time traffic data to determine the user's access behavior characteristics, and the corresponding access behavior change trend is determined based on the access behavior characteristics and a preset association rule mining algorithm; the traffic change trend and the access behavior change trend are input into a set decision tree regression prediction model, and when a traffic peak or abnormal event is detected, the resource allocation of the cloud platform system is dynamically adjusted, thereby effectively improving the flexibility and response speed of the system, optimizing resource utilization, and ensuring the stable operation of the system under peak traffic.

为了能够有效提高系统的灵活性和响应速度,优化资源利用率,确保系统在高峰流量下的稳定运行,本申请提供一种云平台系统流量动态平衡处理方法的实施例,参见图1,所述云平台系统流量动态平衡处理方法具体包含有如下内容:In order to effectively improve the flexibility and response speed of the system, optimize resource utilization, and ensure the stable operation of the system under peak traffic, the present application provides an embodiment of a method for dynamically balancing traffic on a cloud platform system. Referring to FIG. 1 , the method for dynamically balancing traffic on a cloud platform system specifically includes the following contents:

步骤S101:监测云平台系统中的实时流量数据,对设定时间段内的所述实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;Step S101: monitor the real-time traffic data in the cloud platform system, perform time series model analysis on the real-time traffic data within a set time period, and determine the corresponding traffic change trend;

可选的,本实施例中,步骤S101涉及对实时流量数据的监测和时间序列模型分析,以确定流量变化趋势。该步骤的技术过程涉及数据收集、预处理、模型构建与预测等环节,旨在提升流量管理的预见性和资源分配的优化能力。Optionally, in this embodiment, step S101 involves monitoring of real-time traffic data and time series model analysis to determine traffic change trends. The technical process of this step involves data collection, preprocessing, model building and prediction, etc., aiming to improve the predictability of traffic management and the optimization capability of resource allocation.

首先,在步骤S101中,系统实施对云平台内的实时流量数据进行监测。实时流量数据包括用户请求数量、数据传输量、网络带宽使用率等,这些数据通过云平台的监控工具(如Prometheus、Grafana)实时收集和存储。系统配置监控代理,持续捕捉各个服务器节点的流量信息,并将数据汇总到中央数据库中,以便后续分析。First, in step S101, the system implements monitoring of real-time traffic data in the cloud platform. Real-time traffic data includes the number of user requests, data transmission volume, network bandwidth usage, etc. These data are collected and stored in real time through cloud platform monitoring tools (such as Prometheus and Grafana). The system configures a monitoring agent to continuously capture traffic information of each server node and aggregate the data into a central database for subsequent analysis.

接下来,系统对设定时间段内的实时流量数据进行预处理。本实施例包括数据清洗、去噪、缺失值填补和数据归一化等操作,以确保数据质量和一致性。例如,对于不完整的流量数据记录,系统可以采用插值法或移动平均法填补缺失值,同时使用标准化方法将数据缩放到统一的范围内,以消除量级差异的影响。Next, the system preprocesses the real-time traffic data within the set time period. This embodiment includes operations such as data cleaning, denoising, missing value filling, and data normalization to ensure data quality and consistency. For example, for incomplete traffic data records, the system can use interpolation or moving average methods to fill missing values, and use standardization methods to scale the data to a uniform range to eliminate the impact of magnitude differences.

在数据预处理完成后,系统对预处理后的流量数据进行时间序列模型分析。时间序列分析是一种统计方法,用于分析和预测时间序列数据的趋势和周期性波动。系统首先对时间序列数据进行可视化分析,识别出数据的基本特征,如趋势、季节性和随机波动。接着,系统选择合适的时间序列预测模型,如ARIMA(自回归积分滑动平均模型)、SARIMA(季节性自回归积分滑动平均模型)或LSTM(长短期记忆网络),根据数据特征进行模型构建和训练。例如,对于具有明显季节性波动的流量数据,系统可以选择SARIMA模型,通过设定季节性参数,捕捉数据中的周期性变化。After data preprocessing is completed, the system performs time series model analysis on the preprocessed traffic data. Time series analysis is a statistical method used to analyze and predict trends and cyclical fluctuations in time series data. The system first performs a visual analysis of the time series data to identify the basic characteristics of the data, such as trends, seasonality, and random fluctuations. Next, the system selects an appropriate time series prediction model, such as ARIMA (autoregressive integrated moving average model), SARIMA (seasonal autoregressive integrated moving average model), or LSTM (long short-term memory network), and builds and trains the model based on the data characteristics. For example, for traffic data with obvious seasonal fluctuations, the system can select the SARIMA model to capture the cyclical changes in the data by setting seasonal parameters.

模型构建完成后,系统利用训练好的时间序列模型对设定时间段内的流量数据进行预测,确定对应的流量变化趋势。系统输入历史流量数据,模型根据历史数据模式生成未来一段时间的流量预测值。例如,系统可以预测未来一周内每小时的流量变化情况,生成流量趋势图。通过这种方式,系统能够提前识别出流量高峰期和低谷期,从而为资源调度和优化提供数据支撑。After the model is built, the system uses the trained time series model to predict the traffic data within the set time period and determine the corresponding traffic change trend. The system inputs historical traffic data, and the model generates traffic forecasts for a period of time in the future based on the historical data pattern. For example, the system can predict the hourly traffic changes in the next week and generate a traffic trend chart. In this way, the system can identify traffic peaks and troughs in advance, thereby providing data support for resource scheduling and optimization.

本实施例解决了传统流量管理方法在应对动态变化和复杂趋势时的局限性问题。通过实时监测和时间序列分析,系统能够及时捕捉流量变化的细微波动,并基于历史数据进行精准预测,为云平台的资源管理和优化提供科学依据。例如,在预测未来流量高峰期时,系统可以提前进行资源扩容,确保服务质量和用户体验;在流量低谷期,系统则可以进行资源回收和节能操作,降低运营成本。This embodiment solves the limitation of traditional traffic management methods in dealing with dynamic changes and complex trends. Through real-time monitoring and time series analysis, the system can timely capture subtle fluctuations in traffic changes and make accurate predictions based on historical data, providing a scientific basis for resource management and optimization of the cloud platform. For example, when predicting future traffic peaks, the system can expand resources in advance to ensure service quality and user experience; during traffic troughs, the system can perform resource recovery and energy-saving operations to reduce operating costs.

本实施例的技术效果是显著的。通过时间序列模型分析,系统在流量预测和趋势识别方面能够保持高效、准确的预测能力。具体而言,某云平台在实施这一技术方案后,能够更全面地监测和预测流量变化,即使在面对复杂和多变的流量模式时,也能保持高准确率。例如,当系统分析实时流量数据时,无论流量变化多么复杂,系统都能通过时间序列模型准确预测未来的流量趋势,从而及时调整资源配置,提升整体系统的稳定性和性能。The technical effect of this embodiment is significant. Through time series model analysis, the system can maintain efficient and accurate prediction capabilities in traffic forecasting and trend identification. Specifically, after implementing this technical solution, a certain cloud platform can more comprehensively monitor and predict traffic changes, and maintain high accuracy even in the face of complex and changeable traffic patterns. For example, when the system analyzes real-time traffic data, no matter how complex the traffic changes, the system can accurately predict future traffic trends through time series models, thereby adjusting resource allocation in a timely manner and improving the stability and performance of the overall system.

总的来说,步骤S101通过实时流量数据监测和时间序列模型分析,解决了流量管理中的动态变化和复杂趋势问题。通过数据收集、预处理、模型构建和预测的协同工作,系统不仅提高了流量预测的准确性,还确保了资源调度的优化和高效。该技术方案在云平台的流量管理实践中,显著提升了预测和决策的效率,有效降低了运营风险,确保了系统的稳定运行。在实际应用中,云平台通过这一方案,能够更全面地识别和应对流量变化,提升整体资源管理水平,确保服务质量和用户满意度。In general, step S101 solves the problems of dynamic changes and complex trends in traffic management through real-time traffic data monitoring and time series model analysis. Through the collaborative work of data collection, preprocessing, model building and prediction, the system not only improves the accuracy of traffic prediction, but also ensures the optimization and efficiency of resource scheduling. In the traffic management practice of the cloud platform, this technical solution has significantly improved the efficiency of prediction and decision-making, effectively reduced operational risks, and ensured the stable operation of the system. In actual applications, the cloud platform can more comprehensively identify and respond to traffic changes through this solution, improve the overall resource management level, and ensure service quality and user satisfaction.

步骤S102:对与所述实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,根据所述聚类分析的结果确定用户的访问行为特征,并根据所述访问行为特征和通过预设关联规则挖掘算法在用户访问数据集上确定的用户在不同业务场景下访问行为之间的相关性,确定对应的访问行为变化趋势;Step S102: performing cluster analysis on the user access patterns and user access services corresponding to the real-time traffic data, determining the user's access behavior characteristics according to the results of the cluster analysis, and determining the corresponding access behavior change trend according to the access behavior characteristics and the correlation between the user's access behaviors in different business scenarios determined on the user access data set by a preset association rule mining algorithm;

可选的,本实施例中,步骤S102涉及对实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,以确定用户的访问行为特征,并通过关联规则挖掘算法分析用户行为之间的相关性,从而确定访问行为变化趋势。该步骤的技术过程包括聚类分析、特征提取和关联规则挖掘,旨在提升对用户行为的理解和预测能力。Optionally, in this embodiment, step S102 involves clustering analysis of user access patterns and user access services corresponding to real-time traffic data to determine the user's access behavior characteristics, and analyzing the correlation between user behaviors through an association rule mining algorithm to determine the access behavior change trend. The technical process of this step includes cluster analysis, feature extraction, and association rule mining, aiming to improve the understanding and prediction capabilities of user behavior.

首先,在步骤S102中,系统对与实时流量数据相应的用户访问模式和用户访问业务进行聚类分析。聚类分析是一种无监督学习方法,用于将相似的对象分组,以便更好地理解数据的结构和特征。系统首先从实时流量数据中提取用户访问记录,包括访问时间、访问频率、访问页面、业务类型等信息。接着,系统使用K-Means、DBSCAN或层次聚类等算法对用户访问数据进行聚类分析。例如,系统可以使用K-Means算法,根据用户的访问频率和业务类型将用户分为不同的群组(如高频访问用户、低频访问用户、特定业务高频用户等),以识别出不同类型用户的访问模式。First, in step S102, the system performs cluster analysis on the user access patterns and user access services corresponding to the real-time traffic data. Cluster analysis is an unsupervised learning method used to group similar objects in order to better understand the structure and characteristics of the data. The system first extracts user access records from the real-time traffic data, including information such as access time, access frequency, access pages, and service types. Then, the system uses algorithms such as K-Means, DBSCAN, or hierarchical clustering to perform cluster analysis on the user access data. For example, the system can use the K-Means algorithm to divide users into different groups (such as high-frequency access users, low-frequency access users, high-frequency users of specific services, etc.) according to their access frequency and service type to identify the access patterns of different types of users.

在聚类分析完成后,系统根据聚类结果确定用户的访问行为特征。访问行为特征包括用户的访问频率、访问时段偏好、业务类型偏好等。这些特征通过对聚类结果的统计分析和数据可视化展示,可以直观地反映出不同群组用户的行为特征。例如,系统可以发现某一群组用户在晚间时段对视频流媒体业务的访问频率显著高于其他时段,从而确定该群组用户的访问时段偏好和业务类型偏好。After the cluster analysis is completed, the system determines the user's access behavior characteristics based on the clustering results. Access behavior characteristics include the user's access frequency, access time preference, service type preference, etc. These characteristics can intuitively reflect the behavioral characteristics of users in different groups through statistical analysis and data visualization of clustering results. For example, the system can find that the frequency of access to video streaming services by users in a certain group in the evening is significantly higher than that in other periods, thereby determining the access time preference and service type preference of users in this group.

接下来,系统使用预设的关联规则挖掘算法在用户访问数据集上确定用户在不同业务场景下访问行为之间的相关性。关联规则挖掘是一种数据挖掘技术,用于发现数据集中不同项之间的频繁模式和关联关系。系统使用Apriori算法或FP-Growth算法,从用户访问数据集中挖掘出频繁项集和关联规则。例如,系统可以发现“在工作日早上访问新闻页面的用户,通常在午休时间访问社交媒体页面”这一关联规则,从而识别出用户在不同业务场景下的访问行为模式。Next, the system uses a preset association rule mining algorithm to determine the correlation between users' access behaviors in different business scenarios on the user access dataset. Association rule mining is a data mining technique used to discover frequent patterns and associations between different items in a dataset. The system uses the Apriori algorithm or the FP-Growth algorithm to mine frequent item sets and association rules from the user access dataset. For example, the system can discover the association rule that "users who visit news pages on weekday mornings usually visit social media pages during lunch breaks", thereby identifying the user's access behavior patterns in different business scenarios.

通过聚类分析和关联规则挖掘,系统能够确定用户访问行为的变化趋势。访问行为变化趋势反映了用户在不同时间段、不同行为模式下的访问规律,有助于预测未来的用户行为。例如,系统可以根据用户的访问行为特征和关联规则,预测某一群组用户在特定时段的访问量变化趋势,从而为资源调度和业务优化提供依据。Through cluster analysis and association rule mining, the system can determine the changing trend of user access behavior. The changing trend of access behavior reflects the access rules of users in different time periods and different behavior patterns, which helps predict future user behavior. For example, the system can predict the changing trend of the access volume of a group of users in a specific period of time based on the user's access behavior characteristics and association rules, thereby providing a basis for resource scheduling and business optimization.

本实施例解决了传统用户行为分析方法在应对海量数据和动态变化时的局限性问题。通过聚类分析和关联规则挖掘,系统能够深入挖掘用户行为数据中的内在规律和关联关系,为行为预测和个性化服务提供精准支持。例如,在识别出用户的访问行为特征后,系统可以针对高频访问用户提供定制化的业务推荐和优化服务;在发现用户行为之间的关联关系后,系统可以针对不同业务场景进行资源优化配置,提升整体服务质量。This embodiment solves the limitation problem of traditional user behavior analysis methods in dealing with massive data and dynamic changes. Through cluster analysis and association rule mining, the system can deeply explore the inherent laws and associations in user behavior data, and provide accurate support for behavior prediction and personalized services. For example, after identifying the user's access behavior characteristics, the system can provide customized business recommendations and optimization services for high-frequency access users; after discovering the association between user behaviors, the system can optimize resource allocation for different business scenarios to improve the overall service quality.

本实施例的技术效果是显著的。通过聚类分析和关联规则挖掘,系统在用户行为分析和预测方面能够保持高效、准确的分析能力。具体而言,某云平台在实施这一技术方案后,能够更全面地理解和预测用户行为,即使在面对复杂和多变的用户访问模式时,也能保持高准确率。例如,当系统分析实时流量数据时,无论用户行为多么复杂,系统都能通过聚类分析和关联规则挖掘准确识别和预测用户行为变化趋势,从而及时调整业务策略,提升用户体验和满意度。The technical effect of this embodiment is significant. Through cluster analysis and association rule mining, the system can maintain efficient and accurate analysis capabilities in user behavior analysis and prediction. Specifically, after implementing this technical solution, a certain cloud platform can more comprehensively understand and predict user behavior, and maintain high accuracy even in the face of complex and changeable user access patterns. For example, when the system analyzes real-time traffic data, no matter how complex the user behavior is, the system can accurately identify and predict the changing trend of user behavior through cluster analysis and association rule mining, so as to adjust business strategies in a timely manner and improve user experience and satisfaction.

总的来说,步骤S102通过聚类分析和关联规则挖掘,解决了用户行为分析中的复杂性和动态变化问题。通过聚类分析、特征提取和关联规则挖掘的协同工作,系统不仅提高了用户行为分析的准确性,还确保了行为预测和个性化服务的高效。该技术方案在云平台的用户行为分析实践中,显著提升了分析和决策的效率,有效提高了用户满意度和业务运营效率。In general, step S102 solves the complexity and dynamic change problems in user behavior analysis through cluster analysis and association rule mining. Through the collaborative work of cluster analysis, feature extraction and association rule mining, the system not only improves the accuracy of user behavior analysis, but also ensures the efficiency of behavior prediction and personalized services. In the practice of user behavior analysis on the cloud platform, this technical solution significantly improves the efficiency of analysis and decision-making, and effectively improves user satisfaction and business operation efficiency.

步骤S103:将所述流量变化趋势和所述访问行为变化趋势输入设定决策树回归预测模型,根据所述决策树回归预测模型的输出判断是否存在流量高峰或异常事件,当检测到所述流量高峰或异常事件时,根据所述决策树回归预测模型输出的流量变化需求动态调整所述云平台系统的资源分配,并在所述云平台系统的实时流量数据回落至正常水平后释放多余的资源直至恢复标准配置。Step S103: Input the traffic change trend and the access behavior change trend into a set decision tree regression prediction model, and determine whether there is a traffic peak or abnormal event based on the output of the decision tree regression prediction model. When the traffic peak or abnormal event is detected, dynamically adjust the resource allocation of the cloud platform system based on the traffic change demand output by the decision tree regression prediction model, and release excess resources after the real-time traffic data of the cloud platform system drops back to normal levels until the standard configuration is restored.

可选的,本实施例中,步骤S103涉及将流量变化趋势和访问行为变化趋势输入设定的决策树回归预测模型。通过该模型的输出判断是否存在流量高峰或异常事件,并根据模型输出动态调整资源分配。在流量回落至正常水平后,系统释放多余资源直至恢复标准配置。该步骤的技术过程包括数据输入、模型预测、资源调整与恢复,旨在提升云平台的资源管理效率和响应能力。Optionally, in this embodiment, step S103 involves inputting the traffic change trend and the access behavior change trend into a set decision tree regression prediction model. The output of the model is used to determine whether there is a traffic peak or abnormal event, and dynamically adjust resource allocation based on the model output. After the traffic drops back to normal levels, the system releases excess resources until the standard configuration is restored. The technical process of this step includes data input, model prediction, resource adjustment and recovery, aiming to improve the resource management efficiency and responsiveness of the cloud platform.

首先,在步骤S103中,系统将之前步骤S101和S102确定的流量变化趋势和访问行为变化趋势输入到设定的决策树回归预测模型。决策树回归是一种机器学习算法,通过树状结构对数据进行迭代分割,找到最佳的预测结果。系统预先训练一个决策树回归模型,该模型基于历史流量数据和用户行为数据,学习不同特征组合与流量高峰或异常事件之间的关系。训练过程中,系统使用带有标签的历史数据集,通过决策树算法不断分割数据,并调整模型参数,以提高预测准确性。First, in step S103, the system inputs the traffic change trend and access behavior change trend determined in steps S101 and S102 into the set decision tree regression prediction model. Decision tree regression is a machine learning algorithm that iteratively segments data through a tree structure to find the best prediction result. The system pre-trains a decision tree regression model, which is based on historical traffic data and user behavior data to learn the relationship between different feature combinations and traffic peaks or abnormal events. During the training process, the system uses labeled historical data sets, continuously segments data through the decision tree algorithm, and adjusts model parameters to improve prediction accuracy.

在将流量变化趋势和访问行为变化趋势输入到模型后,系统根据决策树回归预测模型的输出结果判断是否存在流量高峰或异常事件。模型输出的结果包括未来一段时间的流量预测值和异常事件的概率值。例如,模型可能预测未来一小时内流量将大幅增加,并给出发生流量高峰的概率。系统根据这些预测结果,判断当前是否需要采取预防措施。After inputting the traffic change trend and access behavior change trend into the model, the system determines whether there is a traffic peak or abnormal event based on the output of the decision tree regression prediction model. The model output includes the traffic forecast value for a period of time in the future and the probability value of abnormal events. For example, the model may predict that the traffic will increase significantly in the next hour and give the probability of a traffic peak. Based on these prediction results, the system determines whether preventive measures need to be taken at the moment.

当检测到流量高峰或异常事件时,系统根据决策树回归预测模型输出的流量变化需求动态调整云平台系统的资源分配。具体而言,系统可以自动扩展服务器实例数量、增加带宽、调整负载均衡策略等。例如,如果模型预测未来一小时内流量将增加至当前的两倍,系统可以提前启动额外的计算资源,以应对即将到来的流量高峰。这样可以确保在流量高峰期间,用户的请求能够得到及时处理,避免因资源不足导致的性能下降或服务中断。When a traffic peak or abnormal event is detected, the system dynamically adjusts the resource allocation of the cloud platform system according to the traffic change demand output by the decision tree regression prediction model. Specifically, the system can automatically expand the number of server instances, increase bandwidth, adjust load balancing strategies, etc. For example, if the model predicts that traffic will increase to twice the current level within the next hour, the system can start additional computing resources in advance to cope with the upcoming traffic peak. This ensures that during traffic peaks, user requests can be processed in a timely manner to avoid performance degradation or service interruptions due to insufficient resources.

在流量高峰或异常事件结束后,系统持续监测实时流量数据,并在流量回落至正常水平后,释放多余的资源直至恢复标准配置。此步骤旨在优化资源使用,降低运营成本。例如,当系统检测到流量已经回落至正常水平,且预测未来不会再出现异常高峰时,系统可以逐步关闭不再需要的计算实例,调整带宽配置,恢复到日常运行状态。本实施例不仅确保了系统在高峰期间的稳定运行,还有效避免了资源浪费。After the traffic peak or abnormal event ends, the system continuously monitors real-time traffic data, and after the traffic drops back to normal levels, it releases excess resources until the standard configuration is restored. This step is intended to optimize resource usage and reduce operating costs. For example, when the system detects that the traffic has dropped back to normal levels and predicts that there will be no more abnormal peaks in the future, the system can gradually shut down computing instances that are no longer needed, adjust bandwidth configuration, and return to normal operation. This embodiment not only ensures the stable operation of the system during peak periods, but also effectively avoids waste of resources.

本实施例解决了传统资源管理方法在应对突发流量和动态变化时的滞后性和低效性问题。通过实时预测和动态调整,系统能够提前识别和应对流量高峰和异常事件,确保资源分配的及时性和有效性。例如,在一次大型在线活动期间,云平台通过这一技术方案,能够提前预测并动态调整资源配置,保障了活动期间的服务稳定运行,避免了因流量激增导致的系统崩溃。This embodiment solves the lag and inefficiency of traditional resource management methods when dealing with sudden traffic and dynamic changes. Through real-time prediction and dynamic adjustment, the system can identify and respond to traffic peaks and abnormal events in advance, ensuring the timeliness and effectiveness of resource allocation. For example, during a large-scale online event, the cloud platform can use this technical solution to predict and dynamically adjust resource allocation in advance, ensuring stable service operation during the event and avoiding system crashes caused by traffic surges.

本实施例的技术效果是显著的。通过决策树回归预测模型,系统在流量预测和资源管理方面能够保持高效、准确的预测和调整能力。具体而言,某云平台在实施这一技术方案后,能够更全面地监测和预测流量变化,即使在面对复杂和多变的流量模式时,也能保持高准确率。例如,当系统分析实时流量数据时,无论流量变化多么复杂,系统都能通过决策树回归模型准确预测未来的流量趋势,从而及时调整资源配置,提升整体系统的稳定性和性能。The technical effect of this embodiment is significant. Through the decision tree regression prediction model, the system can maintain efficient and accurate prediction and adjustment capabilities in traffic prediction and resource management. Specifically, after implementing this technical solution, a certain cloud platform can more comprehensively monitor and predict traffic changes, and maintain high accuracy even in the face of complex and changeable traffic patterns. For example, when the system analyzes real-time traffic data, no matter how complex the traffic changes, the system can accurately predict future traffic trends through the decision tree regression model, thereby adjusting resource allocation in a timely manner and improving the stability and performance of the overall system.

总的来说,步骤S103通过决策树回归预测模型的应用,解决了流量管理中的动态调整和资源优化问题。通过数据输入、模型预测、资源调整与恢复的协同工作,系统不仅提高了流量预测的准确性,还确保了资源管理的高效和灵活。该技术方案在云平台的资源管理实践中,显著提升了预测和决策的效率,有效降低了运营风险,确保了系统的稳定运行。In general, step S103 solves the problem of dynamic adjustment and resource optimization in traffic management by applying the decision tree regression prediction model. Through the collaborative work of data input, model prediction, resource adjustment and recovery, the system not only improves the accuracy of traffic prediction, but also ensures the efficiency and flexibility of resource management. In the resource management practice of the cloud platform, this technical solution significantly improves the efficiency of prediction and decision-making, effectively reduces operational risks, and ensures the stable operation of the system.

从上述描述可知,本申请实施例提供的云平台系统流量动态平衡处理方法,能够通过监测云平台系统中的实时流量数据,对设定时间段内的实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;对与实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,确定用户的访问行为特征,并根据访问行为特征和通过预设关联规则挖掘算法,确定对应的访问行为变化趋势;将流量变化趋势和访问行为变化趋势输入设定决策树回归预测模型,当检测到流量高峰或异常事件时,动态调整云平台系统的资源分配,由此能够有效提高系统的灵活性和响应速度,优化资源利用率,确保系统在高峰流量下的稳定运行。From the above description, it can be seen that the cloud platform system traffic dynamic balancing processing method provided in the embodiment of the present application can monitor the real-time traffic data in the cloud platform system, perform time series model analysis on the real-time traffic data within a set time period, and determine the corresponding traffic change trend; perform cluster analysis on the user access patterns and user access services corresponding to the real-time traffic data to determine the user's access behavior characteristics, and determine the corresponding access behavior change trend based on the access behavior characteristics and through a preset association rule mining algorithm; input the traffic change trend and the access behavior change trend into a set decision tree regression prediction model, and when a traffic peak or abnormal event is detected, dynamically adjust the resource allocation of the cloud platform system, thereby effectively improving the flexibility and response speed of the system, optimizing resource utilization, and ensuring the stable operation of the system under peak traffic.

在本申请的云平台系统流量动态平衡处理方法的一实施例中,参见图2,还可以具体包含如下内容:In one embodiment of the cloud platform system traffic dynamic balancing processing method of the present application, referring to FIG. 2 , the following contents may also be specifically included:

步骤S201:从云平台系统中实时采集用户访问流量数据,对所述用户访问流量数据进行清洗和转换, 并将所述用户访问流量数据转换为时间序列格式;Step S201: collecting user access traffic data from the cloud platform system in real time, cleaning and converting the user access traffic data, and converting the user access traffic data into a time series format;

步骤S202:通过网格搜索确定ARIMA时间序列模型在转换为时间序列格式的用户访问流量数据上预测误差最小的最优参数组合,并根据所述ARIMA时间序列模型的输出确定流量变化趋势。Step S202: determining the optimal parameter combination with the smallest prediction error of the ARIMA time series model on the user access flow data converted into a time series format through grid search, and determining the flow change trend according to the output of the ARIMA time series model.

可选的,本实施例中,步骤S201和步骤S202分别涉及实时采集和处理用户访问流量数据,以及利用ARIMA时间序列模型进行流量预测。具体实现的技术过程包括数据采集、数据清洗与转换、模型参数优化和流量趋势预测。这两个步骤的协同工作旨在提高流量预测的准确性和效率,解决传统方法在大规模数据处理和动态预测中的不足。Optionally, in this embodiment, step S201 and step S202 respectively involve real-time collection and processing of user access traffic data, and traffic forecasting using the ARIMA time series model. The specific technical process includes data collection, data cleaning and conversion, model parameter optimization, and traffic trend forecasting. The collaborative work of these two steps aims to improve the accuracy and efficiency of traffic forecasting and solve the shortcomings of traditional methods in large-scale data processing and dynamic forecasting.

首先,在步骤S201中,系统从云平台中实时采集用户访问流量数据。这些数据包括用户访问的时间、IP地址、请求的资源类型、访问频率等。数据采集模块连接到云平台的流量监控系统,利用流量采集工具(如Fluentd、Logstash)实时收集用户访问日志,并将其传输到数据处理模块进行进一步处理。First, in step S201, the system collects user access traffic data from the cloud platform in real time. This data includes the time of user access, IP address, requested resource type, access frequency, etc. The data collection module is connected to the traffic monitoring system of the cloud platform, and uses traffic collection tools (such as Fluentd, Logstash) to collect user access logs in real time and transmit them to the data processing module for further processing.

接下来,系统对采集到的用户访问流量数据进行清洗和转换。数据清洗的目的是去除噪声和无关信息,确保数据质量。常见的清洗步骤包括去重、处理缺失值和异常值、标准化字段格式等。例如,系统可以去除重复的访问记录,填补缺失的时间戳,或通过统计方法识别并处理异常高频访问记录。数据清洗完成后,系统将清洗后的流量数据转换为时间序列格式。时间序列格式是指数据按照时间顺序排列,每个时间点对应一个或多个观测值。通过这种转换,系统能够保留数据的时间依赖性,便于后续的时间序列分析。Next, the system cleans and converts the collected user access traffic data. The purpose of data cleaning is to remove noise and irrelevant information to ensure data quality. Common cleaning steps include deduplication, processing missing values and outliers, and standardizing field formats. For example, the system can remove duplicate access records, fill in missing timestamps, or identify and process abnormal high-frequency access records through statistical methods. After data cleaning is completed, the system converts the cleaned traffic data into a time series format. The time series format means that the data is arranged in chronological order, and each time point corresponds to one or more observations. Through this conversion, the system can retain the time dependency of the data, which is convenient for subsequent time series analysis.

在步骤S202中,系统利用网格搜索方法确定ARIMA时间序列模型在转换为时间序列格式的用户访问流量数据上的最优参数组合。ARIMA模型(自回归积分滑动平均模型)是一种常用的时间序列预测方法,通过自回归、差分和移动平均三个部分对时间序列数据进行建模。为了找到ARIMA模型的最优参数组合(p, d, q),系统使用网格搜索方法在预定义的参数空间中进行搜索。网格搜索通过对不同参数组合进行穷举搜索,并利用交叉验证方法计算每个组合的预测误差,最终选择预测误差最小的参数组合。例如,系统在参数空间中搜索不同的p(自回归阶数)、d(差分阶数)和q(移动平均阶数),并计算每个组合在验证数据集上的均方误差(MSE),选择MSE最小的组合作为最优参数。In step S202, the system uses a grid search method to determine the optimal parameter combination of the ARIMA time series model on the user access traffic data converted into a time series format. The ARIMA model (autoregressive integrated moving average model) is a commonly used time series prediction method that models time series data through three parts: autoregression, difference, and moving average. In order to find the optimal parameter combination (p, d, q) of the ARIMA model, the system uses a grid search method to search in a predefined parameter space. The grid search performs an exhaustive search for different parameter combinations, and uses a cross-validation method to calculate the prediction error of each combination, and finally selects the parameter combination with the smallest prediction error. For example, the system searches for different p (autoregressive order), d (difference order), and q (moving average order) in the parameter space, and calculates the mean square error (MSE) of each combination on the validation data set, and selects the combination with the smallest MSE as the optimal parameter.

一旦确定了最优参数组合,系统根据ARIMA时间序列模型的输出确定流量变化趋势。模型训练完成后,系统利用该模型对未来的用户访问流量进行预测,生成流量变化趋势图。例如,系统可以预测未来一周内的每日访问流量,并根据预测结果调整资源配置策略,以应对可能的流量波动。Once the optimal parameter combination is determined, the system determines the traffic change trend based on the output of the ARIMA time series model. After the model training is completed, the system uses the model to predict future user access traffic and generate a traffic change trend chart. For example, the system can predict daily access traffic in the next week and adjust resource allocation strategies based on the prediction results to cope with possible traffic fluctuations.

本实施例解决了传统流量预测方法在大规模数据处理和动态变化应对中的局限性问题。通过实时数据采集和清洗,系统能够确保数据的准确性和及时性;通过时间序列转换和ARIMA模型优化,系统能够捕捉数据中的时间依赖性,提高预测的精度和可靠性。例如,在一次电商大促活动期间,云平台通过这一技术方案,能够提前预测并动态调整资源配置,保障了活动期间的服务稳定运行,避免了因流量激增导致的系统崩溃。This embodiment solves the limitations of traditional traffic prediction methods in large-scale data processing and dynamic change response. Through real-time data collection and cleaning, the system can ensure the accuracy and timeliness of the data; through time series conversion and ARIMA model optimization, the system can capture the time dependency in the data and improve the accuracy and reliability of the prediction. For example, during an e-commerce promotion event, the cloud platform was able to predict in advance and dynamically adjust resource allocation through this technical solution, ensuring the stable operation of services during the event and avoiding system crashes caused by traffic surges.

本实施例的技术效果是显著的。通过实时数据处理和优化的ARIMA模型,系统在流量预测方面能够保持高效、准确的预测能力。具体而言,某云平台在实施这一技术方案后,能够更全面地监测和预测流量变化,即使在面对复杂和多变的流量模式时,也能保持高准确率。例如,当系统分析实时流量数据时,无论流量变化多么复杂,系统都能通过ARIMA模型准确预测未来的流量趋势,从而及时调整资源配置,提升整体系统的稳定性和性能。The technical effect of this embodiment is significant. Through real-time data processing and optimized ARIMA models, the system can maintain efficient and accurate prediction capabilities in traffic forecasting. Specifically, after implementing this technical solution, a certain cloud platform can more comprehensively monitor and predict traffic changes, and maintain high accuracy even in the face of complex and changeable traffic patterns. For example, when the system analyzes real-time traffic data, no matter how complex the traffic changes, the system can accurately predict future traffic trends through the ARIMA model, thereby adjusting resource allocation in a timely manner and improving the stability and performance of the overall system.

总的来说,步骤S201和步骤S202通过数据采集、清洗与转换、模型参数优化和趋势预测的协同工作,解决了流量预测中的数据处理和模型优化问题。通过高效的数据处理和精确的模型预测,系统不仅提高了流量预测的准确性,还确保了资源管理的高效和灵活。该技术方案在云平台的流量预测实践中,显著提升了预测和决策的效率,有效降低了运营风险,确保了系统的稳定运行。In general, step S201 and step S202 solve the data processing and model optimization problems in traffic prediction through the collaborative work of data collection, cleaning and conversion, model parameter optimization and trend prediction. Through efficient data processing and accurate model prediction, the system not only improves the accuracy of traffic prediction, but also ensures efficient and flexible resource management. In the practice of traffic prediction on the cloud platform, this technical solution significantly improves the efficiency of prediction and decision-making, effectively reduces operational risks, and ensures the stable operation of the system.

在本申请的云平台系统流量动态平衡处理方法的一实施例中,参见图3,还可以具体包含如下内容:In one embodiment of the cloud platform system traffic dynamic balancing processing method of the present application, referring to FIG. 3 , the following contents may also be specifically included:

步骤S301:获取与所述实时流量数据相对应的用户访问模式和用户访问业务;Step S301: Acquire a user access pattern and a user access service corresponding to the real-time traffic data;

步骤S302:根据所述用户访问模式、所述用户访问业务以及预设K-Means聚类算法将用户划分为不同类型的群体, 确定用户的访问行为特征,其中,每个群体都有独特的访问行为特征。Step S302: Divide the users into different types of groups according to the user access patterns, the user access services and a preset K-Means clustering algorithm, and determine the user access behavior characteristics, wherein each group has unique access behavior characteristics.

可选的,本实施例中,步骤S301和步骤S302分别涉及获取用户访问模式和业务,以及利用K-Means聚类算法对用户进行分类。这两个步骤的协同工作旨在识别不同用户群体的访问特征,从而提高系统的响应能力和优化资源配置。Optionally, in this embodiment, step S301 and step S302 respectively involve obtaining user access patterns and services, and classifying users using the K-Means clustering algorithm. The collaboration of these two steps is intended to identify access characteristics of different user groups, thereby improving the system's responsiveness and optimizing resource allocation.

首先,在步骤S301中,系统从实时流量数据中提取与用户访问相关的信息。用户访问模式包括用户的访问频率、访问时间段、访问时长、访问路径等,而用户访问业务则涉及用户在平台上进行的具体操作,如浏览商品、添加购物车、下单支付等。系统通过结合日志分析工具和用户行为分析平台(如Google Analytics、Mixpanel)实时采集这些数据,并进行初步处理。例如,系统可以从访问日志中提取每个用户的IP地址、访问时间戳、请求URL等信息,并将这些信息与用户在平台上的操作记录关联起来,形成完整的用户访问记录。First, in step S301, the system extracts information related to user access from real-time traffic data. User access patterns include user access frequency, access time period, access duration, access path, etc., while user access services involve specific operations performed by users on the platform, such as browsing products, adding shopping carts, placing orders and paying, etc. The system collects this data in real time and performs preliminary processing by combining log analysis tools and user behavior analysis platforms (such as Google Analytics and Mixpanel). For example, the system can extract each user's IP address, access timestamp, request URL and other information from the access log, and associate this information with the user's operation records on the platform to form a complete user access record.

接下来,在步骤S302中,系统利用预设的K-Means聚类算法,根据用户访问模式和访问业务将用户划分为不同类型的群体。K-Means聚类是一种无监督学习算法,通过最小化群内平方误差,将数据点划分为K个簇。具体实现过程中,系统首先对用户访问数据进行特征提取和标准化处理,如将用户的访问频率、访问时长、业务操作次数等转换为数值特征,并进行归一化处理。然后,系统将这些特征向量输入K-Means算法,设定初始簇数K,算法通过迭代优化找到最优的簇中心和用户群体划分。例如,对于一个电商平台,系统可以设定K=5,将用户划分为五个群体,如高频购买用户、浏览用户、偶尔购买用户等。Next, in step S302, the system uses the preset K-Means clustering algorithm to divide users into different types of groups according to their access patterns and access services. K-Means clustering is an unsupervised learning algorithm that divides data points into K clusters by minimizing the square error within the group. In the specific implementation process, the system first extracts features and normalizes the user access data, such as converting the user's access frequency, access duration, number of business operations, etc. into numerical features and normalizing them. Then, the system inputs these feature vectors into the K-Means algorithm, sets the initial number of clusters K, and the algorithm finds the optimal cluster center and user group division through iterative optimization. For example, for an e-commerce platform, the system can set K=5 and divide users into five groups, such as high-frequency purchasing users, browsing users, occasional purchasing users, etc.

通过K-Means聚类,系统能够确定每个群体的访问行为特征。每个群体都有独特的访问模式和业务操作习惯。例如,高频购买用户可能表现出较高的访问频率、较短的访问间隔、频繁的下单操作,而浏览用户则可能表现出长时间的页面停留和较少的购买操作。系统通过分析这些特征,为不同用户群体制定差异化的服务策略和资源配置方案。例如,对于高频购买用户,系统可以优先分配更多的计算资源和带宽,以保证其访问体验;对于浏览用户,系统可以通过个性化推荐和营销策略,提高其转化率。Through K-Means clustering, the system can determine the access behavior characteristics of each group. Each group has unique access patterns and business operation habits. For example, high-frequency purchasing users may show high access frequency, short access intervals, and frequent ordering operations, while browsing users may show long page stays and fewer purchase operations. By analyzing these characteristics, the system formulates differentiated service strategies and resource allocation plans for different user groups. For example, for high-frequency purchasing users, the system can prioritize the allocation of more computing resources and bandwidth to ensure their access experience; for browsing users, the system can improve their conversion rate through personalized recommendations and marketing strategies.

本实施例解决了传统用户行为分析方法在处理大规模用户数据和动态行为识别中的不足。通过实时数据采集和K-Means聚类,系统能够快速识别不同用户群体的行为特征,提升数据分析的效率和准确性。例如,在一次大型促销活动期间,系统通过这一技术方案,能够提前识别出高频购买用户和潜在购买用户,针对性地推送优惠信息和资源,显著提高了活动的转化率和用户满意度。This embodiment solves the shortcomings of traditional user behavior analysis methods in processing large-scale user data and dynamic behavior identification. Through real-time data collection and K-Means clustering, the system can quickly identify the behavioral characteristics of different user groups and improve the efficiency and accuracy of data analysis. For example, during a large-scale promotional event, the system can use this technical solution to identify high-frequency purchasing users and potential purchasing users in advance, and push preferential information and resources in a targeted manner, significantly improving the conversion rate and user satisfaction of the event.

本实施例的技术效果是显著的。通过实时用户行为分析和优化的聚类算法,系统在用户分类和行为识别方面能够保持高效、准确的分析能力。具体而言,某云平台在实施这一技术方案后,能够更全面地监测和分析用户行为,即使在面对复杂和多变的用户访问模式时,也能保持高准确率。例如,当系统分析实时用户数据时,无论用户行为多么复杂,系统都能通过K-Means聚类准确识别不同用户群体的特征,从而制定更为精准的营销和资源配置策略,提升整体系统的响应能力和用户满意度。The technical effect of this embodiment is significant. Through real-time user behavior analysis and optimized clustering algorithms, the system can maintain efficient and accurate analysis capabilities in user classification and behavior identification. Specifically, after implementing this technical solution, a certain cloud platform can more comprehensively monitor and analyze user behavior, and maintain high accuracy even in the face of complex and changeable user access patterns. For example, when the system analyzes real-time user data, no matter how complex the user behavior is, the system can accurately identify the characteristics of different user groups through K-Means clustering, thereby formulating more accurate marketing and resource allocation strategies, and improving the overall system's responsiveness and user satisfaction.

总的来说,步骤S301和步骤S302通过数据采集、行为分析、聚类算法的协同工作,解决了用户行为分析中的数据处理和动态识别问题。通过高效的数据处理和精确的聚类分析,系统不仅提高了用户分类和行为识别的准确性,还确保了资源管理的高效和灵活。该技术方案在云平台的用户行为分析实践中,显著提升了分析和决策的效率,有效降低了运营风险,确保了系统的稳定运行。In general, step S301 and step S302 solve the data processing and dynamic identification problems in user behavior analysis through the collaborative work of data collection, behavior analysis, and clustering algorithms. Through efficient data processing and precise clustering analysis, the system not only improves the accuracy of user classification and behavior identification, but also ensures efficient and flexible resource management. In the practice of user behavior analysis on the cloud platform, this technical solution significantly improves the efficiency of analysis and decision-making, effectively reduces operational risks, and ensures the stable operation of the system.

在本申请的云平台系统流量动态平衡处理方法的一实施例中,参见图4,还可以具体包含如下内容:In one embodiment of the cloud platform system traffic dynamic balancing processing method of the present application, referring to FIG. 4 , the following contents may also be specifically included:

步骤S401:根据用户访问行为特征分析确定不同用户群体的访问行为;Step S401: determining the access behaviors of different user groups based on user access behavior feature analysis;

步骤S402:利用Apriori关联规则挖掘算法在用户访问数据集上确定不同用户群体在各自业务场景下的访问行为之间的相关性,并根据所述相关性确定对应的访问行为变化趋势。Step S402: using the Apriori association rule mining algorithm to determine the correlation between the access behaviors of different user groups in their respective business scenarios on the user access data set, and determining the corresponding access behavior change trend according to the correlation.

可选的,本实施例中,步骤S401和步骤S402分别涉及根据用户访问行为特征分析不同用户群体的访问行为,以及利用Apriori关联规则挖掘算法确定这些行为之间的相关性。通过这两个步骤,系统能够深入理解用户行为模式,识别不同用户群体在各自业务场景下的访问行为变化趋势,从而优化资源配置和用户体验。Optionally, in this embodiment, step S401 and step S402 respectively involve analyzing the access behaviors of different user groups according to the user access behavior characteristics, and determining the correlation between these behaviors using the Apriori association rule mining algorithm. Through these two steps, the system can deeply understand the user behavior patterns, identify the access behavior change trends of different user groups in their respective business scenarios, and thus optimize resource allocation and user experience.

首先,在步骤S401中,系统根据之前通过K-Means聚类算法划分的不同用户群体,分析其详细的访问行为特征。这些特征包括用户的访问频率、访问时间段、访问路径、停留时间以及具体的业务操作(如商品浏览、购物车操作、订单提交等)。系统通过对这些行为特征的分析,能够识别出每个用户群体的典型行为模式。例如,高频购买用户可能主要集中在特定时间段内频繁访问并进行多次购买操作;而浏览用户可能在多个时间段内长时间停留在商品详情页面,但实际购买行为较少。通过对这些特征的分析,系统能够构建各个用户群体的行为特征模型,为后续的关联规则挖掘提供基础数据。First, in step S401, the system analyzes the detailed access behavior characteristics of different user groups previously divided by the K-Means clustering algorithm. These characteristics include the user's access frequency, access time period, access path, residence time, and specific business operations (such as product browsing, shopping cart operations, order submission, etc.). By analyzing these behavioral characteristics, the system can identify the typical behavior patterns of each user group. For example, high-frequency purchasing users may mainly visit frequently and make multiple purchases within a specific time period; while browsing users may stay on the product details page for a long time in multiple time periods, but have fewer actual purchase behaviors. By analyzing these characteristics, the system can build a behavioral feature model for each user group and provide basic data for subsequent association rule mining.

接下来,在步骤S402中,系统利用Apriori关联规则挖掘算法在用户访问数据集上确定不同用户群体在各自业务场景下的访问行为之间的相关性。Apriori算法是一种经典的关联规则挖掘算法,旨在发现数据集中频繁出现的项集及其关联规则。具体实现过程中,系统首先将用户的访问行为转化为事务数据集,每个事务代表一个用户在特定时间段内的访问行为序列。然后,系统应用Apriori算法,在这些事务数据集中挖掘频繁项集和关联规则。例如,系统可以发现高频购买用户在访问商品详情页面后,通常会添加商品到购物车并在短时间内完成购买;或者浏览用户在访问多个商品详情页面后,可能会在特定类型的商品上停留较长时间但最终没有下单。Next, in step S402, the system uses the Apriori association rule mining algorithm to determine the correlation between the access behaviors of different user groups in their respective business scenarios on the user access data set. The Apriori algorithm is a classic association rule mining algorithm that aims to discover frequently occurring item sets and their association rules in a data set. In the specific implementation process, the system first converts the user's access behavior into a transaction data set, and each transaction represents a sequence of access behaviors of a user in a specific time period. Then, the system applies the Apriori algorithm to mine frequent item sets and association rules in these transaction data sets. For example, the system can find that high-frequency purchasing users usually add products to the shopping cart and complete the purchase in a short time after visiting the product details page; or browsing users may stay on a specific type of product for a long time after visiting multiple product details pages but ultimately do not place an order.

通过关联规则挖掘,系统能够识别出不同用户群体在各自业务场景下的典型行为模式及其变化趋势。例如,系统可以发现高频购买用户在价格波动或促销活动期间的购买行为变化趋势,或者浏览用户在特定商品类型(如电子产品、服装)上的关注度和访问路径变化。基于这些关联规则和行为趋势分析,系统能够为不同用户群体制定个性化的营销策略和资源配置方案。例如,针对高频购买用户,系统可以在促销活动期间进行精准推送,并提供限时优惠;针对浏览用户,系统可以通过个性化推荐提高其购买转化率。Through association rule mining, the system can identify the typical behavior patterns and changing trends of different user groups in their respective business scenarios. For example, the system can discover the changing trends of the purchasing behavior of high-frequency purchasing users during price fluctuations or promotional activities, or the changes in the attention and access paths of browsing users on specific types of goods (such as electronic products and clothing). Based on these association rules and behavioral trend analysis, the system can formulate personalized marketing strategies and resource allocation plans for different user groups. For example, for high-frequency purchasing users, the system can accurately push during promotional activities and provide limited-time discounts; for browsing users, the system can improve their purchase conversion rate through personalized recommendations.

本实施例解决了传统用户行为分析方法在处理复杂行为模式和动态变化中的不足。通过详细的行为特征分析和关联规则挖掘,系统能够深入理解不同用户群体的行为模式和变化趋势,提高数据分析的深度和准确性。例如,在一次大型促销活动中,系统通过这一技术方案,能够提前识别出哪些用户群体对哪些商品最感兴趣,并针对性地推送优惠信息和资源配置,显著提高了活动的转化率和用户满意度。This embodiment solves the shortcomings of traditional user behavior analysis methods in dealing with complex behavior patterns and dynamic changes. Through detailed behavior feature analysis and association rule mining, the system can deeply understand the behavior patterns and change trends of different user groups, and improve the depth and accuracy of data analysis. For example, in a large-scale promotional event, the system can use this technical solution to identify in advance which user groups are most interested in which products, and push preferential information and resource allocation in a targeted manner, significantly improving the conversion rate and user satisfaction of the event.

本实施例的技术效果是显著的。通过详细的行为特征分析和优化的关联规则挖掘算法,系统在用户行为模式识别和变化趋势分析方面能够保持高效、准确的分析能力。具体而言,某云平台在实施这一技术方案后,能够更全面地监测和分析用户行为,即使在面对复杂和多变的用户访问模式时,也能保持高准确率。例如,当系统分析实时用户数据时,无论用户行为多么复杂,系统都能通过Apriori算法准确识别不同用户群体的行为关联和变化趋势,从而制定更为精准的营销和资源配置策略,提升整体系统的响应能力和用户满意度。The technical effect of this embodiment is significant. Through detailed behavioral feature analysis and optimized association rule mining algorithms, the system can maintain efficient and accurate analysis capabilities in user behavior pattern recognition and change trend analysis. Specifically, after implementing this technical solution, a certain cloud platform can more comprehensively monitor and analyze user behavior, and maintain high accuracy even in the face of complex and changeable user access patterns. For example, when the system analyzes real-time user data, no matter how complex the user behavior is, the system can accurately identify the behavioral associations and change trends of different user groups through the Apriori algorithm, thereby formulating more accurate marketing and resource allocation strategies, and improving the overall system's responsiveness and user satisfaction.

总的来说,步骤S401和步骤S402通过行为特征分析、关联规则挖掘的协同工作,解决了用户行为分析中的复杂行为模式识别和动态变化预测问题。通过高效的数据处理和精确的行为模式分析,系统不仅提高了用户行为识别的准确性,还确保了资源管理的高效和灵活。该技术方案在云平台的用户行为分析实践中,显著提升了分析和决策的效率,有效降低了运营风险,确保了系统的稳定运行。In general, step S401 and step S402 solve the problem of complex behavior pattern recognition and dynamic change prediction in user behavior analysis through the collaborative work of behavior feature analysis and association rule mining. Through efficient data processing and precise behavior pattern analysis, the system not only improves the accuracy of user behavior recognition, but also ensures efficient and flexible resource management. In the practice of user behavior analysis on the cloud platform, this technical solution significantly improves the efficiency of analysis and decision-making, effectively reduces operational risks, and ensures the stable operation of the system.

在本申请的云平台系统流量动态平衡处理方法的一实施例中,参见图5,还可以具体包含如下内容:In one embodiment of the cloud platform system traffic dynamic balancing processing method of the present application, referring to FIG5 , the following contents may also be specifically included:

步骤S501:根据历史样本数据训练决策树回归预测模型直至形成最优预测规则,将所述流量变化趋势和所述访问行为变化趋势输入设定决策树回归预测模型;Step S501: training a decision tree regression prediction model according to historical sample data until an optimal prediction rule is formed, and inputting the traffic change trend and the access behavior change trend into a set decision tree regression prediction model;

步骤S502:根据所述决策树回归预测模型输出的预测概率数值与预设阈值的数值比较关系判断是否存在流量高峰或异常事件。Step S502: Determine whether there is a traffic peak or abnormal event based on the comparison relationship between the predicted probability value output by the decision tree regression prediction model and the value of a preset threshold.

可选的,本实施例中,步骤S501和步骤S502分别涉及训练决策树回归预测模型以及利用该模型判断是否存在流量高峰或异常事件。通过这两个步骤,系统能够准确地预测未来的流量变化,并及时识别潜在的流量高峰或异常事件,从而优化系统资源配置和提高用户体验。Optionally, in this embodiment, step S501 and step S502 respectively involve training a decision tree regression prediction model and using the model to determine whether there is a traffic peak or an abnormal event. Through these two steps, the system can accurately predict future traffic changes and promptly identify potential traffic peaks or abnormal events, thereby optimizing system resource allocation and improving user experience.

首先,在步骤S501中,系统根据历史样本数据训练决策树回归预测模型。决策树回归是一种常用的机器学习算法,能够通过构建树状模型来预测连续数值。具体实现过程中,系统首先收集并整理历史流量数据和用户访问行为数据,这些数据包括不同时段的用户访问量、页面点击数、访问路径、停留时间以及业务操作记录等。接着,系统对这些数据进行预处理,如数据清洗、特征提取和标准化处理,以确保数据质量和模型训练效果。First, in step S501, the system trains a decision tree regression prediction model based on historical sample data. Decision tree regression is a commonly used machine learning algorithm that can predict continuous values by building a tree model. In the specific implementation process, the system first collects and organizes historical traffic data and user access behavior data, which include user visits, page clicks, access paths, dwell time, and business operation records in different time periods. Then, the system preprocesses these data, such as data cleaning, feature extraction, and standardization, to ensure data quality and model training effect.

在数据预处理完成后,系统将处理后的数据集输入决策树回归算法进行训练。训练过程中,系统通过不断分裂数据集,优化每个节点的分裂条件,以最小化预测误差,并最终形成最优预测规则。例如,系统可以通过决策树回归模型预测未来一小时内的访问量,依据历史数据中的访问模式和业务操作来确定访问量的变化趋势。当模型训练完成后,系统将流量变化趋势和访问行为变化趋势输入已训练好的决策树回归模型进行预测,生成未来一段时间内的流量变化预测值。After data preprocessing is completed, the system inputs the processed data set into the decision tree regression algorithm for training. During the training process, the system continuously splits the data set and optimizes the splitting conditions of each node to minimize the prediction error and eventually form the optimal prediction rule. For example, the system can use the decision tree regression model to predict the number of visits in the next hour, and determine the trend of the number of visits based on the access patterns and business operations in the historical data. When the model training is completed, the system inputs the traffic change trend and the access behavior change trend into the trained decision tree regression model for prediction, and generates the predicted value of traffic change in the future period of time.

接下来,在步骤S502中,系统根据决策树回归预测模型输出的预测概率数值与预设阈值的数值比较关系,判断是否存在流量高峰或异常事件。具体来说,系统将预测得到的流量变化值与设定的流量阈值进行比较,如果预测值超过阈值,则判定可能存在流量高峰或异常事件。例如,系统可以设定一个流量阈值,如果预测访问量超过该阈值,则系统将在后台触发告警,并采取相应的应对措施,如增加服务器资源、调整负载均衡策略等。Next, in step S502, the system determines whether there is a traffic peak or abnormal event based on the comparison relationship between the predicted probability value output by the decision tree regression prediction model and the value of the preset threshold. Specifically, the system compares the predicted traffic change value with the set traffic threshold. If the predicted value exceeds the threshold, it is determined that there may be a traffic peak or abnormal event. For example, the system can set a traffic threshold. If the predicted access volume exceeds the threshold, the system will trigger an alarm in the background and take corresponding countermeasures, such as increasing server resources, adjusting the load balancing strategy, etc.

本实施例解决了传统流量预测方法在处理大规模数据和动态变化中的不足。通过历史数据训练决策树回归模型,系统能够根据用户访问行为和流量变化趋势,准确预测未来的流量变化,并及时识别潜在的流量高峰或异常事件。例如,在一次大型促销活动前夕,系统通过这一技术方案,能够提前预测到活动期间的流量高峰,并预先增加服务器资源和带宽配置,确保活动期间系统的稳定运行和用户的良好体验。This embodiment solves the shortcomings of traditional traffic prediction methods in processing large-scale data and dynamic changes. By training the decision tree regression model with historical data, the system can accurately predict future traffic changes based on user access behavior and traffic change trends, and promptly identify potential traffic peaks or abnormal events. For example, on the eve of a large-scale promotional event, the system can use this technical solution to predict the traffic peak during the event in advance, and increase server resources and bandwidth configuration in advance to ensure stable operation of the system and a good user experience during the event.

本实施例的技术效果是显著的。通过高效的决策树回归预测模型和精准的流量高峰判断算法,系统在流量预测和异常事件识别方面能够保持高效、准确的分析能力。具体而言,某云平台在实施这一技术方案后,能够更全面地监测和预测用户流量,即使在面对复杂和多变的用户访问模式时,也能保持高准确率。例如,当系统分析实时用户数据时,无论流量变化多么复杂,系统都能通过决策树回归模型准确预测未来的流量变化,并及时识别潜在的流量高峰和异常事件,从而制定更为精准的资源配置和应对策略,提升整体系统的响应能力和用户满意度。The technical effect of this embodiment is significant. Through an efficient decision tree regression prediction model and an accurate traffic peak judgment algorithm, the system can maintain efficient and accurate analysis capabilities in traffic prediction and abnormal event identification. Specifically, after implementing this technical solution, a certain cloud platform can more comprehensively monitor and predict user traffic, and maintain high accuracy even in the face of complex and changeable user access patterns. For example, when the system analyzes real-time user data, no matter how complex the traffic changes, the system can accurately predict future traffic changes through a decision tree regression model, and promptly identify potential traffic peaks and abnormal events, thereby formulating more accurate resource allocation and response strategies, and improving the overall system's responsiveness and user satisfaction.

总的来说,步骤S501和步骤S502通过历史数据训练、决策树回归预测和流量高峰判断的协同工作,解决了流量预测和异常事件识别中的数据处理和动态变化问题。通过高效的数据处理和精确的预测分析,系统不仅提高了流量预测的准确性,还确保了资源管理的高效和灵活。该技术方案在云平台的流量预测实践中,显著提升了分析和决策的效率,有效降低了运营风险,确保了系统的稳定运行。In general, step S501 and step S502 solve the data processing and dynamic change problems in traffic prediction and abnormal event identification through the collaborative work of historical data training, decision tree regression prediction and traffic peak judgment. Through efficient data processing and accurate prediction analysis, the system not only improves the accuracy of traffic prediction, but also ensures efficient and flexible resource management. In the practice of traffic prediction on the cloud platform, this technical solution significantly improves the efficiency of analysis and decision-making, effectively reduces operational risks, and ensures the stable operation of the system.

在本申请的云平台系统流量动态平衡处理方法的一实施例中,参见图6,还可以具体包含如下内容:In one embodiment of the cloud platform system traffic dynamic balancing processing method of the present application, referring to FIG. 6 , the following contents may also be specifically included:

步骤S601:当检测到存在流量高峰或异常事件时,根据所述决策树回归预测模型的输出,确定导致异常的关键因素;Step S601: when a traffic peak or an abnormal event is detected, the key factors causing the abnormality are determined according to the output of the decision tree regression prediction model;

步骤S602:根据决策树回归模型预测的流量变化需求和所述导致异常的关键因素动态调整云平台系统的资源分配策略。Step S602: Dynamically adjust the resource allocation strategy of the cloud platform system according to the traffic change demand predicted by the decision tree regression model and the key factors causing the anomaly.

可选的,本实施例中,步骤S601和步骤S602分别涉及检测流量高峰或异常事件时确定导致异常的关键因素,以及根据预测的流量变化需求和关键因素动态调整资源分配策略。通过这两个步骤,系统能够及时识别并应对流量异常,确保系统稳定运行和用户体验的提升。Optionally, in this embodiment, step S601 and step S602 respectively involve determining the key factors causing the anomaly when detecting a traffic peak or an abnormal event, and dynamically adjusting the resource allocation strategy according to the predicted traffic change demand and the key factors. Through these two steps, the system can identify and respond to traffic anomalies in a timely manner, ensuring stable operation of the system and improving user experience.

首先,在步骤S601中,当系统检测到存在流量高峰或异常事件时,依据决策树回归预测模型的输出,确定导致异常的关键因素。具体实现过程中,系统会利用前期训练好的决策树回归模型,对当前和历史流量数据进行分析。当模型输出的预测值超过预设的阈值,表明可能出现了流量高峰或异常事件,系统会启动异常原因分析模块。该模块通过反向解析决策树模型,找出影响预测结果的主要特征和节点。例如,如果系统检测到某时间段内访问量突然激增,模型可能会指出这是由于特定用户群体的集中访问、某一促销活动的启动、或者是某一业务功能的异常使用引起的。First, in step S601, when the system detects the presence of a traffic peak or an abnormal event, the key factors causing the abnormality are determined based on the output of the decision tree regression prediction model. In the specific implementation process, the system will use the previously trained decision tree regression model to analyze the current and historical traffic data. When the predicted value output by the model exceeds the preset threshold, indicating that a traffic peak or an abnormal event may have occurred, the system will start the abnormal cause analysis module. This module reversely parses the decision tree model to find out the main features and nodes that affect the prediction results. For example, if the system detects a sudden surge in visits within a certain period of time, the model may indicate that this is caused by concentrated visits by a specific user group, the launch of a promotional activity, or abnormal use of a business function.

通过确定异常的关键因素,系统能够更精准地了解流量异常的根本原因。例如,在一次促销活动期间,系统可能发现访问量激增是由于大量用户集中在短时间内访问某一特定商品页面,或者是由于用户在结算页面遇到问题而频繁刷新页面。识别出这些关键因素后,系统可以更有针对性地采取措施,解决潜在问题,减少不必要的资源浪费。By identifying the key factors of the anomaly, the system can more accurately understand the root cause of the traffic anomaly. For example, during a promotion, the system may find that the surge in traffic is due to a large number of users visiting a specific product page in a short period of time, or because users frequently refresh the page when they encounter problems on the checkout page. After identifying these key factors, the system can take more targeted measures to solve potential problems and reduce unnecessary waste of resources.

接下来,在步骤S602中,系统根据决策树回归模型预测的流量变化需求和导致异常的关键因素,动态调整云平台系统的资源分配策略。具体来说,系统会根据预测的流量需求和识别出的关键因素,实时调整服务器资源、网络带宽、缓存策略等。例如,如果预测到某一时间段内将出现访问高峰,系统可以提前增加相应的服务器实例,扩展网络带宽,确保用户访问的顺畅和快速响应。如果检测到某一业务功能存在异常导致流量激增,系统可以临时调整该功能的服务策略,限制其访问频率或优化其处理流程,以减轻系统负载。Next, in step S602, the system dynamically adjusts the resource allocation strategy of the cloud platform system according to the traffic change demand predicted by the decision tree regression model and the key factors causing the anomaly. Specifically, the system will adjust server resources, network bandwidth, cache strategy, etc. in real time according to the predicted traffic demand and identified key factors. For example, if it is predicted that there will be a peak in access within a certain time period, the system can increase the corresponding server instances in advance and expand the network bandwidth to ensure smooth user access and quick response. If a business function is detected to have an anomaly that causes a surge in traffic, the system can temporarily adjust the service strategy of the function, limit its access frequency or optimize its processing flow to reduce the system load.

本实施例解决了传统资源分配方法在面对突发流量变化时的滞后性和不灵活性问题。通过实时监控和动态调整,系统能够在流量高峰或异常事件发生时,迅速响应并调整资源配置,确保系统的稳定性和高效运行。例如,在一次突发的用户访问高峰中,系统通过这一技术方案,能够及时增加服务器资源和网络带宽,防止系统过载和服务中断,保障用户的良好体验。This embodiment solves the lag and inflexibility of traditional resource allocation methods when facing sudden traffic changes. Through real-time monitoring and dynamic adjustment, the system can quickly respond and adjust resource allocation when traffic peaks or abnormal events occur, ensuring the stability and efficient operation of the system. For example, during a sudden user access peak, the system can increase server resources and network bandwidth in a timely manner through this technical solution, prevent system overload and service interruption, and ensure a good user experience.

本实施例的技术效果是显著的。通过精准的异常分析和动态资源调整,系统在流量管理和资源优化方面能够保持高效、灵活的响应能力。具体而言,某云平台在实施这一技术方案后,能够更全面地监测和应对流量变化,即使在面对复杂和多变的用户访问模式时,也能保持高准确率。例如,当系统分析实时用户数据时,无论流量变化多么复杂,系统都能通过决策树回归模型和动态调整策略,准确预测未来的流量需求,并及时调整资源配置,提升整体系统的响应能力和用户满意度。The technical effect of this embodiment is significant. Through precise anomaly analysis and dynamic resource adjustment, the system can maintain efficient and flexible response capabilities in terms of traffic management and resource optimization. Specifically, after implementing this technical solution, a certain cloud platform can more comprehensively monitor and respond to traffic changes, and maintain high accuracy even in the face of complex and changeable user access patterns. For example, when the system analyzes real-time user data, no matter how complex the traffic changes, the system can accurately predict future traffic demands through decision tree regression models and dynamic adjustment strategies, and adjust resource allocation in a timely manner to improve the overall system's responsiveness and user satisfaction.

总的来说,步骤S601和步骤S602通过异常检测、关键因素分析和动态资源调整的协同工作,解决了流量管理中的数据处理和资源分配问题。通过高效的数据处理和精确的预测分析,系统不仅提高了流量管理的准确性,还确保了资源管理的灵活性和高效性。该技术方案在云平台的流量管理实践中,显著提升了分析和决策的效率,有效降低了运营风险,确保了系统的稳定运行。In general, step S601 and step S602 solve the data processing and resource allocation problems in traffic management through the collaborative work of anomaly detection, key factor analysis and dynamic resource adjustment. Through efficient data processing and accurate predictive analysis, the system not only improves the accuracy of traffic management, but also ensures the flexibility and efficiency of resource management. In the practice of traffic management on the cloud platform, this technical solution significantly improves the efficiency of analysis and decision-making, effectively reduces operational risks, and ensures the stable operation of the system.

在本申请的云平台系统流量动态平衡处理方法的一实施例中,参见图7,还可以具体包含如下内容:In one embodiment of the cloud platform system traffic dynamic balancing processing method of the present application, referring to FIG. 7 , the following contents may also be specifically included:

步骤S701:对所述云平台系统的实时流量数据进行监测;Step S701: monitoring the real-time traffic data of the cloud platform system;

步骤S702:在监测所述云平台系统的实时流量数据回落至正常水平后逐步缩减计算节点数量和存储空间直至系统的资源配置完全恢复到事先设定的标准状态。Step S702: After monitoring the real-time traffic data of the cloud platform system and returning to a normal level, gradually reduce the number of computing nodes and storage space until the resource configuration of the system is completely restored to a pre-set standard state.

可选的,本实施例中,步骤S701和步骤S702分别涉及对系统的实时流量数据进行监测,以及在流量数据回落至正常水平后逐步缩减计算节点数量和存储空间直至资源配置恢复到标准状态。通过这两个步骤,系统能够有效地管理资源,确保在流量高峰期的稳定运行,并在流量回落后优化资源利用率。Optionally, in this embodiment, step S701 and step S702 respectively involve monitoring the real-time traffic data of the system, and gradually reducing the number of computing nodes and storage space after the traffic data falls back to a normal level until the resource configuration returns to a standard state. Through these two steps, the system can effectively manage resources, ensure stable operation during peak traffic periods, and optimize resource utilization after the traffic falls back.

首先,在步骤S701中,系统对实时流量数据进行监测。具体实现过程中,系统会部署多个监测节点,这些节点分布在不同的服务器和网络设备上,实时采集用户访问量、页面点击数、请求响应时间、带宽使用情况等关键指标。系统通过数据采集模块,将这些实时数据汇总到中央监控平台,进行统一分析和处理。实时流量监测的技术原理主要依靠数据采集、传输和分析技术,确保数据的实时性和准确性。例如,系统可以每秒钟采集一次流量数据,并通过流量监控算法,实时分析数据波动情况,识别潜在的流量高峰或异常事件。First, in step S701, the system monitors real-time traffic data. In the specific implementation process, the system will deploy multiple monitoring nodes, which are distributed on different servers and network devices to collect key indicators such as user visits, page clicks, request response time, and bandwidth usage in real time. The system uses the data acquisition module to aggregate these real-time data to the central monitoring platform for unified analysis and processing. The technical principle of real-time traffic monitoring mainly relies on data acquisition, transmission and analysis technology to ensure the real-time and accuracy of data. For example, the system can collect traffic data once a second, and use the traffic monitoring algorithm to analyze data fluctuations in real time and identify potential traffic peaks or abnormal events.

通过实时流量监测,系统能够及时发现和响应流量变化,确保在流量高峰期提供足够的计算和存储资源。例如,在一次促销活动期间,系统通过实时监测发现用户访问量迅速增加,系统可以立即启动自动扩展机制,增加计算节点和存储空间,防止系统过载和服务中断。同时,实时监测还可以帮助系统识别潜在的安全威胁,如DDoS攻击,通过及时告警和启动防护措施,保障系统的安全性和稳定性。Through real-time traffic monitoring, the system can promptly detect and respond to traffic changes, ensuring that sufficient computing and storage resources are provided during peak traffic periods. For example, during a promotional event, the system discovered through real-time monitoring that user traffic increased rapidly. The system can immediately start the automatic expansion mechanism to increase computing nodes and storage space to prevent system overload and service interruption. At the same time, real-time monitoring can also help the system identify potential security threats, such as DDoS attacks, and ensure the security and stability of the system through timely warnings and the initiation of protective measures.

接下来,在步骤S702中,当监测到实时流量数据回落至正常水平后,系统逐步缩减计算节点数量和存储空间,直至资源配置完全恢复到事先设定的标准状态。具体来说,系统会根据实时流量数据的变化趋势,逐步关闭或释放部分计算节点和存储资源。例如,如果系统监测到用户访问量逐渐减少,系统会根据预设的资源缩减策略,先关闭或释放负载较低的计算节点,逐步减少带宽和存储分配,确保资源的高效利用。Next, in step S702, when the real-time traffic data is monitored to fall back to normal levels, the system gradually reduces the number of computing nodes and storage space until the resource configuration is fully restored to the pre-set standard state. Specifically, the system will gradually shut down or release some computing nodes and storage resources according to the changing trend of real-time traffic data. For example, if the system monitors that the user access volume is gradually decreasing, the system will first shut down or release the computing nodes with lower loads according to the preset resource reduction strategy, gradually reduce bandwidth and storage allocation, and ensure efficient use of resources.

本实施例解决了传统资源管理方法在面对动态流量变化时的滞后性和资源浪费问题。通过实时监测和动态调整,系统能够在流量高峰期提供足够的资源支持,并在流量回落后及时缩减资源配置,避免资源浪费。例如,在一次大型促销活动结束后,系统通过这一技术方案,能够准确识别流量回落的时间点,并逐步缩减计算节点和存储空间,确保系统资源的最优配置和高效利用。This embodiment solves the lag and resource waste problems of traditional resource management methods when facing dynamic traffic changes. Through real-time monitoring and dynamic adjustment, the system can provide sufficient resource support during traffic peaks, and reduce resource allocation in time after traffic drops to avoid resource waste. For example, after a large-scale promotional event, the system can accurately identify the time point when traffic drops through this technical solution, and gradually reduce computing nodes and storage space to ensure the optimal configuration and efficient use of system resources.

本实施例的技术效果是显著的。通过精准的实时流量监测和动态资源调整,系统在资源管理和优化方面能够保持高效、灵活的响应能力。具体而言,某云平台在实施这一技术方案后,能够更全面地监测和应对流量变化,无论在流量高峰期还是回落期,都能保持高效的资源利用率。例如,当系统分析实时用户数据时,无论流量变化多么复杂,系统都能通过实时监测和动态调整策略,准确识别流量变化趋势,并及时调整资源配置,提升整体系统的响应能力和用户满意度。The technical effect of this embodiment is significant. Through accurate real-time traffic monitoring and dynamic resource adjustment, the system can maintain efficient and flexible response capabilities in resource management and optimization. Specifically, after implementing this technical solution, a certain cloud platform can more comprehensively monitor and respond to traffic changes, and maintain efficient resource utilization regardless of traffic peaks or declines. For example, when the system analyzes real-time user data, no matter how complex the traffic changes, the system can accurately identify traffic change trends through real-time monitoring and dynamic adjustment strategies, and adjust resource allocation in a timely manner, thereby improving the overall system's responsiveness and user satisfaction.

总的来说,步骤S701和步骤S702通过实时流量监测和动态资源调整的协同工作,解决了流量管理中的动态变化和资源优化问题。通过高效的数据处理和精确的监测分析,系统不仅提高了流量管理的准确性,还确保了资源管理的灵活性和高效性。该技术方案在云平台的流量管理实践中,显著提升了分析和决策的效率,有效降低了运营风险,确保了系统的稳定运行。平台系统的实时流量数据回落至正常水平后逐步缩减计算节点数量和存储空间直至系统的资源配置完全恢复到事先设定的标准状态。In general, step S701 and step S702 solve the problems of dynamic changes and resource optimization in traffic management through the collaborative work of real-time traffic monitoring and dynamic resource adjustment. Through efficient data processing and precise monitoring and analysis, the system not only improves the accuracy of traffic management, but also ensures the flexibility and efficiency of resource management. In the traffic management practice of the cloud platform, this technical solution has significantly improved the efficiency of analysis and decision-making, effectively reduced operational risks, and ensured the stable operation of the system. After the real-time traffic data of the platform system falls back to normal levels, the number of computing nodes and storage space are gradually reduced until the system's resource configuration is fully restored to the pre-set standard state.

可选的,本实施例中,Optionally, in this embodiment,

为了能够有效提高系统的灵活性和响应速度,优化资源利用率,确保系统在高峰流量下的稳定运行,本申请提供一种用于实现所述云平台系统流量动态平衡处理方法的全部或部分内容的云平台系统流量动态平衡处理装置的实施例,参见图8,所述云平台系统流量动态平衡处理装置具体包含有如下内容:In order to effectively improve the flexibility and response speed of the system, optimize resource utilization, and ensure the stable operation of the system under peak traffic, the present application provides an embodiment of a cloud platform system traffic dynamic balancing processing device for implementing all or part of the content of the cloud platform system traffic dynamic balancing processing method. Referring to FIG. 8 , the cloud platform system traffic dynamic balancing processing device specifically includes the following content:

流量变化确定模块10,用于监测云平台系统中的实时流量数据,对设定时间段内的所述实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;The flow change determination module 10 is used to monitor the real-time flow data in the cloud platform system, perform time series model analysis on the real-time flow data within a set time period, and determine the corresponding flow change trend;

访问行为确定模块20,用于对与所述实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,根据所述聚类分析的结果确定用户的访问行为特征,并根据所述访问行为特征和通过预设关联规则挖掘算法在用户访问数据集上确定的用户在不同业务场景下访问行为之间的相关性,确定对应的访问行为变化趋势;The access behavior determination module 20 is used to perform cluster analysis on the user access patterns and user access services corresponding to the real-time traffic data, determine the user's access behavior characteristics according to the results of the cluster analysis, and determine the corresponding access behavior change trend according to the access behavior characteristics and the correlation between the user's access behaviors in different business scenarios determined on the user access data set by a preset association rule mining algorithm;

异常预测模块30,用于将所述流量变化趋势和所述访问行为变化趋势输入设定决策树回归预测模型,根据所述决策树回归预测模型的输出判断是否存在流量高峰或异常事件,当检测到所述流量高峰或异常事件时,根据所述决策树回归预测模型输出的流量变化需求动态调整所述云平台系统的资源分配,并在所述云平台系统的实时流量数据回落至正常水平后释放多余的资源直至恢复标准配置。The abnormal prediction module 30 is used to input the traffic change trend and the access behavior change trend into a set decision tree regression prediction model, and determine whether there is a traffic peak or an abnormal event based on the output of the decision tree regression prediction model. When the traffic peak or abnormal event is detected, the resource allocation of the cloud platform system is dynamically adjusted according to the traffic change demand output by the decision tree regression prediction model, and after the real-time traffic data of the cloud platform system drops back to a normal level, excess resources are released until the standard configuration is restored.

从上述描述可知,本申请实施例提供的云平台系统流量动态平衡处理装置,能够通过监测云平台系统中的实时流量数据,对设定时间段内的实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;对与实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,确定用户的访问行为特征,并根据访问行为特征和通过预设关联规则挖掘算法,确定对应的访问行为变化趋势;将流量变化趋势和访问行为变化趋势输入设定决策树回归预测模型,当检测到流量高峰或异常事件时,动态调整云平台系统的资源分配,由此能够有效提高系统的灵活性和响应速度,优化资源利用率,确保系统在高峰流量下的稳定运行。From the above description, it can be seen that the cloud platform system traffic dynamic balancing processing device provided in the embodiment of the present application can monitor the real-time traffic data in the cloud platform system, perform time series model analysis on the real-time traffic data within a set time period, and determine the corresponding traffic change trend; perform cluster analysis on the user access patterns and user access services corresponding to the real-time traffic data to determine the user's access behavior characteristics, and determine the corresponding access behavior change trend based on the access behavior characteristics and through a preset association rule mining algorithm; input the traffic change trend and the access behavior change trend into a set decision tree regression prediction model, and when a traffic peak or abnormal event is detected, dynamically adjust the resource allocation of the cloud platform system, thereby effectively improving the flexibility and response speed of the system, optimizing resource utilization, and ensuring the stable operation of the system under peak traffic.

从硬件层面来说,为了能够有效提高系统的灵活性和响应速度,优化资源利用率,确保系统在高峰流量下的稳定运行,本申请提供一种用于实现所述云平台系统流量动态平衡处理方法中的全部或部分内容的电子设备的实施例,所述电子设备具体包含有如下内容:From the hardware level, in order to effectively improve the flexibility and response speed of the system, optimize resource utilization, and ensure the stable operation of the system under peak traffic, the present application provides an embodiment of an electronic device for implementing all or part of the content of the cloud platform system traffic dynamic balancing processing method, and the electronic device specifically includes the following content:

处理器(processor) 、存储器(memory) 、通信接口(Communications Interface)和总线;其中,所述处理器、存储器、通信接口通过所述总线完成相互间的通信;所述通信接口用于实现云平台系统流量动态平衡处理装置与核心业务系统、用户终端以及相关数据库等相关设备之间的信息传输;该逻辑控制器可以是台式计算机、平板电脑及移动终端等,本实施例不限于此。在本实施例中,该逻辑控制器可以参照实施例中的云平台系统流量动态平衡处理方法的实施例,以及云平台系统流量动态平衡处理装置的实施例进行实施,其内容被合并于此,重复之处不再赘述。Processor, memory, communication interface and bus; wherein the processor, memory and communication interface communicate with each other through the bus; the communication interface is used to realize information transmission between the cloud platform system traffic dynamic balancing processing device and the core business system, user terminal and related database and other related devices; the logic controller can be a desktop computer, a tablet computer and a mobile terminal, etc., but the present embodiment is not limited thereto. In the present embodiment, the logic controller can be implemented with reference to the embodiment of the cloud platform system traffic dynamic balancing processing method and the embodiment of the cloud platform system traffic dynamic balancing processing device in the embodiment, and the contents thereof are incorporated herein, and the repeated parts are not repeated.

可以理解的是,所述用户终端可以包括智能手机、平板电子设备、网络机顶盒、便携式计算机、台式电脑、个人数字助理(PDA)、车载设备、智能穿戴设备等。其中,所述智能穿戴设备可以包括智能眼镜、智能手表、智能手环等。It is understandable that the user terminal may include a smart phone, a tablet electronic device, a network set-top box, a portable computer, a desktop computer, a personal digital assistant (PDA), a vehicle-mounted device, a smart wearable device, etc. Among them, the smart wearable device may include smart glasses, a smart watch, a smart bracelet, etc.

在实际应用中,云平台系统流量动态平衡处理方法的部分可以在如上述内容所述的电子设备侧执行,也可以所有的操作都在所述客户端设备中完成。具体可以根据所述客户端设备的处理能力,以及用户使用场景的限制等进行选择。本申请对此不作限定。若所有的操作都在所述客户端设备中完成,所述客户端设备还可以包括处理器。In practical applications, part of the cloud platform system traffic dynamic balancing processing method can be executed on the electronic device side as described above, or all operations can be completed in the client device. The specific selection can be based on the processing capability of the client device and the limitations of the user's usage scenario. This application does not limit this. If all operations are completed in the client device, the client device may also include a processor.

上述的客户端设备可以具有通信模块(即通信单元),可以与远程的服务器进行通信连接,实现与所述服务器的数据传输。所述服务器可以包括任务调度中心一侧的服务器,其他的实施场景中也可以包括中间平台的服务器,例如与任务调度中心服务器有通信链接的第三方服务器平台的服务器。所述的服务器可以包括单台计算机设备,也可以包括多个服务器组成的服务器集群,或者分布式装置的服务器结构。The client device may have a communication module (i.e., a communication unit) that can communicate with a remote server to achieve data transmission with the server. The server may include a server on the task scheduling center side, and other implementation scenarios may also include a server on an intermediate platform, such as a server on a third-party server platform that has a communication link with the task scheduling center server. The server may include a single computer device, or a server cluster consisting of multiple servers, or a server structure of a distributed device.

图9为本申请实施例的电子设备9600的系统构成的示意框图。如图9所示,该电子设备9600可以包括中央处理器9100和存储器9140;存储器9140耦合到中央处理器9100。值得注意的是,该图9是示例性的;还可以使用其他类型的结构,来补充或代替该结构,以实现电信功能或其他功能。FIG9 is a schematic block diagram of a system structure of an electronic device 9600 according to an embodiment of the present application. As shown in FIG9 , the electronic device 9600 may include a central processor 9100 and a memory 9140; the memory 9140 is coupled to the central processor 9100. It is worth noting that FIG9 is exemplary; other types of structures may also be used to supplement or replace the structure to implement telecommunication functions or other functions.

一实施例中,云平台系统流量动态平衡处理方法功能可以被集成到中央处理器9100中。其中,中央处理器9100可以被配置为进行如下控制:In one embodiment, the cloud platform system traffic dynamic balancing processing method function may be integrated into the central processor 9100. The central processor 9100 may be configured to perform the following control:

步骤S101:监测云平台系统中的实时流量数据,对设定时间段内的所述实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;Step S101: monitor the real-time traffic data in the cloud platform system, perform time series model analysis on the real-time traffic data within a set time period, and determine the corresponding traffic change trend;

步骤S102:对与所述实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,根据所述聚类分析的结果确定用户的访问行为特征,并根据所述访问行为特征和通过预设关联规则挖掘算法在用户访问数据集上确定的用户在不同业务场景下访问行为之间的相关性,确定对应的访问行为变化趋势;Step S102: performing cluster analysis on the user access patterns and user access services corresponding to the real-time traffic data, determining the user's access behavior characteristics according to the results of the cluster analysis, and determining the corresponding access behavior change trend according to the access behavior characteristics and the correlation between the user's access behaviors in different business scenarios determined on the user access data set by a preset association rule mining algorithm;

步骤S103:将所述流量变化趋势和所述访问行为变化趋势输入设定决策树回归预测模型,根据所述决策树回归预测模型的输出判断是否存在流量高峰或异常事件,当检测到所述流量高峰或异常事件时,根据所述决策树回归预测模型输出的流量变化需求动态调整所述云平台系统的资源分配,并在所述云平台系统的实时流量数据回落至正常水平后释放多余的资源直至恢复标准配置。Step S103: Input the traffic change trend and the access behavior change trend into a set decision tree regression prediction model, and determine whether there is a traffic peak or abnormal event based on the output of the decision tree regression prediction model. When the traffic peak or abnormal event is detected, dynamically adjust the resource allocation of the cloud platform system based on the traffic change demand output by the decision tree regression prediction model, and release excess resources after the real-time traffic data of the cloud platform system drops back to normal levels until the standard configuration is restored.

从上述描述可知,本申请实施例提供的电子设备,通过监测云平台系统中的实时流量数据,对设定时间段内的实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;对与实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,确定用户的访问行为特征,并根据访问行为特征和通过预设关联规则挖掘算法,确定对应的访问行为变化趋势;将流量变化趋势和访问行为变化趋势输入设定决策树回归预测模型,当检测到流量高峰或异常事件时,动态调整云平台系统的资源分配,由此能够有效提高系统的灵活性和响应速度,优化资源利用率,确保系统在高峰流量下的稳定运行。From the above description, it can be seen that the electronic device provided in the embodiment of the present application monitors the real-time traffic data in the cloud platform system, performs time series model analysis on the real-time traffic data within a set time period, and determines the corresponding traffic change trend; performs cluster analysis on the user access patterns and user access services corresponding to the real-time traffic data to determine the user's access behavior characteristics, and determines the corresponding access behavior change trend based on the access behavior characteristics and through a preset association rule mining algorithm; inputs the traffic change trend and the access behavior change trend into a set decision tree regression prediction model, and dynamically adjusts the resource allocation of the cloud platform system when a traffic peak or abnormal event is detected, thereby effectively improving the flexibility and response speed of the system, optimizing resource utilization, and ensuring stable operation of the system under peak traffic.

在另一个实施方式中,云平台系统流量动态平衡处理装置可以与中央处理器9100分开配置,例如可以将云平台系统流量动态平衡处理装置配置为与中央处理器9100连接的芯片,通过中央处理器的控制来实现云平台系统流量动态平衡处理方法功能。In another embodiment, the cloud platform system traffic dynamic balancing processing device can be configured separately from the central processor 9100. For example, the cloud platform system traffic dynamic balancing processing device can be configured as a chip connected to the central processor 9100, and the cloud platform system traffic dynamic balancing processing method function can be realized through the control of the central processor.

如图9所示,该电子设备9600还可以包括:通信模块9110、输入单元9120、音频处理器9130、显示器9160、电源9170。值得注意的是,电子设备9600也并不是必须要包括图9中所示的所有部件;此外,电子设备9600还可以包括图9中没有示出的部件,可以参考现有技术。As shown in FIG9 , the electronic device 9600 may further include: a communication module 9110, an input unit 9120, an audio processor 9130, a display 9160, and a power supply 9170. It is worth noting that the electronic device 9600 does not necessarily include all the components shown in FIG9 ; in addition, the electronic device 9600 may also include components not shown in FIG9 , and reference may be made to the prior art.

如图9所示,中央处理器9100有时也称为控制器或操作控件,可以包括微处理器或其他处理器装置和/或逻辑装置,该中央处理器9100接收输入并控制电子设备9600的各个部件的操作。As shown in FIG. 9 , the central processor 9100 is sometimes also referred to as a controller or an operation control, and may include a microprocessor or other processor device and/or logic device. The central processor 9100 receives input and controls the operation of various components of the electronic device 9600 .

其中,存储器9140,例如可以是缓存器、闪存、硬驱、可移动介质、易失性存储器、非易失性存储器或其它合适装置中的一种或更多种。可储存上述与失败有关的信息,此外还可存储执行有关信息的程序。并且中央处理器9100可执行该存储器9140存储的该程序,以实现信息存储或处理等。The memory 9140 may be, for example, one or more of a cache, a flash memory, a hard drive, a removable medium, a volatile memory, a non-volatile memory or other suitable devices. The above-mentioned information related to the failure may be stored, and a program for executing the relevant information may also be stored. The CPU 9100 may execute the program stored in the memory 9140 to implement information storage or processing.

输入单元9120向中央处理器9100提供输入。该输入单元9120例如为按键或触摸输入装置。电源9170用于向电子设备9600提供电力。显示器9160用于进行图像和文字等显示对象的显示。该显示器例如可为LCD显示器,但并不限于此。The input unit 9120 provides input to the central processing unit 9100. The input unit 9120 is, for example, a key or a touch input device. The power supply 9170 is used to provide power to the electronic device 9600. The display 9160 is used to display display objects such as images and texts. The display may be, for example, an LCD display, but is not limited thereto.

该存储器9140可以是固态存储器,例如,只读存储器(ROM)、随机存取存储器(RAM)、SIM卡等。还可以是这样的存储器,其即使在断电时也保存信息,可被选择性地擦除且设有更多数据,该存储器的示例有时被称为EPROM等。存储器9140还可以是某种其它类型的装置。存储器9140包括缓冲存储器9141(有时被称为缓冲器)。存储器9140可以包括应用/功能存储部9142,该应用/功能存储部9142用于存储应用程序和功能程序或用于通过中央处理器9100执行电子设备9600的操作的流程。The memory 9140 may be a solid-state memory, such as a read-only memory (ROM), a random access memory (RAM), a SIM card, etc. It may also be a memory that saves information even when the power is off, can be selectively erased, and is provided with more data, examples of which are sometimes referred to as EPROMs, etc. The memory 9140 may also be some other type of device. The memory 9140 includes a buffer memory 9141 (sometimes referred to as a buffer). The memory 9140 may include an application/function storage unit 9142, which is used to store application programs and function programs or processes for executing the operation of the electronic device 9600 through the central processor 9100.

存储器9140还可以包括数据存储部9143,该数据存储部9143用于存储数据,例如联系人、数字数据、图片、声音和/或任何其他由电子设备使用的数据。存储器9140的驱动程序存储部9144可以包括电子设备的用于通信功能和/或用于执行电子设备的其他功能(如消息传送应用、通讯录应用等)的各种驱动程序。The memory 9140 may also include a data storage unit 9143 for storing data, such as contacts, digital data, pictures, sounds, and/or any other data used by the electronic device. The driver storage unit 9144 of the memory 9140 may include various drivers for communication functions of the electronic device and/or for executing other functions of the electronic device (such as messaging applications, address book applications, etc.).

通信模块9110即为经由天线9111发送和接收信号的发送机/接收机。通信模块9110(发送机/接收机)耦合到中央处理器9100,以提供输入信号和接收输出信号,这可以和常规移动通信终端的情况相同。The communication module 9110 is a transmitter/receiver that sends and receives signals via the antenna 9111. The communication module 9110 (transmitter/receiver) is coupled to the central processor 9100 to provide input signals and receive output signals, which may be the same as the case of a conventional mobile communication terminal.

基于不同的通信技术,在同一电子设备中,可以设置有多个通信模块9110,如蜂窝网络模块、蓝牙模块和/或无线局域网模块等。通信模块9110(发送机/接收机)还经由音频处理器9130耦合到扬声器9131和麦克风9132,以经由扬声器9131提供音频输出,并接收来自麦克风9132的音频输入,从而实现通常的电信功能。音频处理器9130可以包括任何合适的缓冲器、解码器、放大器等。另外,音频处理器9130还耦合到中央处理器9100,从而使得可以通过麦克风9132能够在本机上录音,且使得可以通过扬声器9131来播放本机上存储的声音。Based on different communication technologies, multiple communication modules 9110 may be provided in the same electronic device, such as a cellular network module, a Bluetooth module and/or a wireless LAN module, etc. The communication module 9110 (transmitter/receiver) is also coupled to a speaker 9131 and a microphone 9132 via an audio processor 9130 to provide an audio output via the speaker 9131 and receive an audio input from the microphone 9132, thereby realizing a common telecommunication function. The audio processor 9130 may include any suitable buffer, decoder, amplifier, etc. In addition, the audio processor 9130 is also coupled to the central processor 9100, so that recording can be performed on the local machine through the microphone 9132, and the sound stored on the local machine can be played through the speaker 9131.

本申请的实施例还提供能够实现上述实施例中的执行主体为服务器或客户端的云平台系统流量动态平衡处理方法中全部步骤的一种计算机可读存储介质,所述计算机可读存储介质上存储有计算机程序,该计算机程序被处理器执行时实现上述实施例中的执行主体为服务器或客户端的云平台系统流量动态平衡处理方法的全部步骤,例如,所述处理器执行所述计算机程序时实现下述步骤:The embodiments of the present application also provide a computer-readable storage medium capable of implementing all the steps of the method for dynamically balancing the flow of a cloud platform system in the above-mentioned embodiment, where the execution subject is a server or a client. The computer-readable storage medium stores a computer program, and when the computer program is executed by a processor, all the steps of the method for dynamically balancing the flow of a cloud platform system in the above-mentioned embodiment are implemented. For example, when the processor executes the computer program, the following steps are implemented:

步骤S101:监测云平台系统中的实时流量数据,对设定时间段内的所述实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;Step S101: monitor the real-time traffic data in the cloud platform system, perform time series model analysis on the real-time traffic data within a set time period, and determine the corresponding traffic change trend;

步骤S102:对与所述实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,根据所述聚类分析的结果确定用户的访问行为特征,并根据所述访问行为特征和通过预设关联规则挖掘算法在用户访问数据集上确定的用户在不同业务场景下访问行为之间的相关性,确定对应的访问行为变化趋势;Step S102: performing cluster analysis on the user access patterns and user access services corresponding to the real-time traffic data, determining the user's access behavior characteristics according to the results of the cluster analysis, and determining the corresponding access behavior change trend according to the access behavior characteristics and the correlation between the user's access behaviors in different business scenarios determined on the user access data set by a preset association rule mining algorithm;

步骤S103:将所述流量变化趋势和所述访问行为变化趋势输入设定决策树回归预测模型,根据所述决策树回归预测模型的输出判断是否存在流量高峰或异常事件,当检测到所述流量高峰或异常事件时,根据所述决策树回归预测模型输出的流量变化需求动态调整所述云平台系统的资源分配,并在所述云平台系统的实时流量数据回落至正常水平后释放多余的资源直至恢复标准配置。Step S103: Input the traffic change trend and the access behavior change trend into a set decision tree regression prediction model, and determine whether there is a traffic peak or abnormal event based on the output of the decision tree regression prediction model. When the traffic peak or abnormal event is detected, dynamically adjust the resource allocation of the cloud platform system based on the traffic change demand output by the decision tree regression prediction model, and release excess resources after the real-time traffic data of the cloud platform system drops back to normal levels until the standard configuration is restored.

从上述描述可知,本申请实施例提供的计算机可读存储介质,通过监测云平台系统中的实时流量数据,对设定时间段内的实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;对与实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,确定用户的访问行为特征,并根据访问行为特征和通过预设关联规则挖掘算法,确定对应的访问行为变化趋势;将流量变化趋势和访问行为变化趋势输入设定决策树回归预测模型,当检测到流量高峰或异常事件时,动态调整云平台系统的资源分配,由此能够有效提高系统的灵活性和响应速度,优化资源利用率,确保系统在高峰流量下的稳定运行。From the above description, it can be seen that the computer-readable storage medium provided in the embodiment of the present application monitors the real-time traffic data in the cloud platform system, performs time series model analysis on the real-time traffic data within a set time period, and determines the corresponding traffic change trend; performs cluster analysis on the user access patterns and user access services corresponding to the real-time traffic data to determine the user's access behavior characteristics, and determines the corresponding access behavior change trend based on the access behavior characteristics and through a preset association rule mining algorithm; inputs the traffic change trend and the access behavior change trend into a set decision tree regression prediction model, and dynamically adjusts the resource allocation of the cloud platform system when a traffic peak or abnormal event is detected, thereby effectively improving the flexibility and response speed of the system, optimizing resource utilization, and ensuring the stable operation of the system under peak traffic.

本申请的实施例还提供能够实现上述实施例中的执行主体为服务器或客户端的云平台系统流量动态平衡处理方法中全部步骤的一种计算机程序产品,该计算机程序/指令被处理器执行时实现所述的云平台系统流量动态平衡处理方法的步骤,例如,所述计算机程序/指令实现下述步骤:The embodiments of the present application also provide a computer program product capable of implementing all the steps of the method for dynamically balancing the flow of a cloud platform system in the above embodiments, where the execution subject is a server or a client. When the computer program/instruction is executed by a processor, the steps of the method for dynamically balancing the flow of a cloud platform system are implemented. For example, the computer program/instruction implements the following steps:

步骤S101:监测云平台系统中的实时流量数据,对设定时间段内的所述实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;Step S101: monitor the real-time traffic data in the cloud platform system, perform time series model analysis on the real-time traffic data within a set time period, and determine the corresponding traffic change trend;

步骤S102:对与所述实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,根据所述聚类分析的结果确定用户的访问行为特征,并根据所述访问行为特征和通过预设关联规则挖掘算法在用户访问数据集上确定的用户在不同业务场景下访问行为之间的相关性,确定对应的访问行为变化趋势;Step S102: performing cluster analysis on the user access patterns and user access services corresponding to the real-time traffic data, determining the user's access behavior characteristics according to the results of the cluster analysis, and determining the corresponding access behavior change trend according to the access behavior characteristics and the correlation between the user's access behaviors in different business scenarios determined on the user access data set by a preset association rule mining algorithm;

步骤S103:将所述流量变化趋势和所述访问行为变化趋势输入设定决策树回归预测模型,根据所述决策树回归预测模型的输出判断是否存在流量高峰或异常事件,当检测到所述流量高峰或异常事件时,根据所述决策树回归预测模型输出的流量变化需求动态调整所述云平台系统的资源分配,并在所述云平台系统的实时流量数据回落至正常水平后释放多余的资源直至恢复标准配置。Step S103: Input the traffic change trend and the access behavior change trend into a set decision tree regression prediction model, and determine whether there is a traffic peak or abnormal event based on the output of the decision tree regression prediction model. When the traffic peak or abnormal event is detected, dynamically adjust the resource allocation of the cloud platform system based on the traffic change demand output by the decision tree regression prediction model, and release excess resources after the real-time traffic data of the cloud platform system drops back to normal levels until the standard configuration is restored.

从上述描述可知,本申请实施例提供的计算机程序产品,通过监测云平台系统中的实时流量数据,对设定时间段内的实时流量数据进行时间序列模型分析,确定对应的流量变化趋势;对与实时流量数据相应的用户访问模式和用户访问业务进行聚类分析,确定用户的访问行为特征,并根据访问行为特征和通过预设关联规则挖掘算法,确定对应的访问行为变化趋势;将流量变化趋势和访问行为变化趋势输入设定决策树回归预测模型,当检测到流量高峰或异常事件时,动态调整云平台系统的资源分配,由此能够有效提高系统的灵活性和响应速度,优化资源利用率,确保系统在高峰流量下的稳定运行。From the above description, it can be seen that the computer program product provided in the embodiment of the present application monitors the real-time traffic data in the cloud platform system, performs time series model analysis on the real-time traffic data within a set time period, and determines the corresponding traffic change trend; performs cluster analysis on the user access patterns and user access services corresponding to the real-time traffic data to determine the user's access behavior characteristics, and determines the corresponding access behavior change trend based on the access behavior characteristics and through a preset association rule mining algorithm; inputs the traffic change trend and the access behavior change trend into a set decision tree regression prediction model, and dynamically adjusts the resource allocation of the cloud platform system when a traffic peak or abnormal event is detected, thereby effectively improving the flexibility and response speed of the system, optimizing resource utilization, and ensuring the stable operation of the system under peak traffic.

本领域内的技术人员应明白,本发明的实施例可提供为方法、装置、或计算机程序产品。因此,本发明可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且,本发明可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。It should be understood by those skilled in the art that the embodiments of the present invention may be provided as methods, devices, or computer program products. Therefore, the present invention may take the form of a complete hardware embodiment, a complete software embodiment, or an embodiment combining software and hardware aspects. Moreover, the present invention may take the form of a computer program product implemented on one or more computer-usable storage media (including but not limited to disk storage, CD-ROM, optical storage, etc.) containing computer-usable program code.

本发明是参照根据本发明实施例的方法、设备(装置)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器,使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。The present invention is described with reference to the flowchart and/or block diagram of the method, device (apparatus), and computer program product according to the embodiment of the present invention. It should be understood that each process and/or box in the flowchart and/or block diagram, as well as the combination of the processes and/or boxes in the flowchart and/or block diagram, can be implemented by computer program instructions. These computer program instructions can be provided to a processor of a general-purpose computer, a special-purpose computer, an embedded processor, or other programmable data processing device to generate a machine, so that the instructions executed by the processor of the computer or other programmable data processing device generate a device for implementing the functions specified in one process or multiple processes in the flowchart and/or one box or multiple boxes in the block diagram.

这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中,使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品,该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。These computer program instructions may also be stored in a computer-readable memory that can direct a computer or other programmable data processing device to work in a specific manner, so that the instructions stored in the computer-readable memory produce a manufactured product including an instruction device that implements the functions specified in one or more processes in the flowchart and/or one or more boxes in the block diagram.

这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上,使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理,从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。These computer program instructions may also be loaded onto a computer or other programmable data processing device so that a series of operational steps are executed on the computer or other programmable device to produce a computer-implemented process, whereby the instructions executed on the computer or other programmable device provide steps for implementing the functions specified in one or more processes in the flowchart and/or one or more boxes in the block diagram.

本发明中应用了具体实施例对本发明的原理及实施方式进行了阐述,以上实施例的说明只是用于帮助理解本发明的方法及其核心思想;同时,对于本领域的一般技术人员,依据本发明的思想,在具体实施方式及应用范围上均会有改变之处,综上所述,本说明书内容不应理解为对本发明的限制。The present invention uses specific embodiments to illustrate the principles and implementation methods of the present invention. The description of the above embodiments is only used to help understand the method of the present invention and its core idea. At the same time, for those skilled in the art, according to the idea of the present invention, there will be changes in the specific implementation methods and application scope. In summary, the content of this specification should not be understood as a limitation on the present invention.

Claims (10)

1. The method for dynamically balancing and processing the flow of the cloud platform system is characterized by comprising the following steps of:
monitoring real-time flow data in a cloud platform system, performing time sequence model analysis on the real-time flow data in a set time period, and determining a corresponding flow change trend;
Performing cluster analysis on a user access mode and a user access service corresponding to the real-time flow data, determining access behavior characteristics of the user according to the result of the cluster analysis, and determining corresponding access behavior change trend according to the access behavior characteristics and the correlation between the access behaviors of the user determined on a user access data set through a preset association rule mining algorithm under different service scenes;
And inputting the flow change trend and the access behavior change trend into a set decision tree regression prediction model, judging whether a flow peak or an abnormal event exists according to the output of the decision tree regression prediction model, dynamically adjusting the resource allocation of the cloud platform system according to the flow change demand output by the decision tree regression prediction model when the flow peak or the abnormal event is detected, and releasing redundant resources until standard configuration is restored after the real-time flow data of the cloud platform system fall back to a normal level.
2. The method for dynamically balancing flow of a cloud platform system according to claim 1, wherein the monitoring real-time flow data in the cloud platform system, performing time-series model analysis on the real-time flow data in a set period of time, and determining a corresponding flow change trend, includes:
Collecting user access flow data in real time from a cloud platform system, cleaning and converting the user access flow data, and converting the user access flow data into a time sequence format;
And determining an optimal parameter combination with the minimum prediction error of the ARIMA time sequence model on the user access flow data converted into the time sequence format through grid search, and determining the flow change trend according to the output of the ARIMA time sequence model.
3. The method for dynamically balancing the flow of the cloud platform system according to claim 1, wherein the performing cluster analysis on the user access mode and the user access service corresponding to the real-time flow data, and determining the access behavior feature of the user according to the result of the cluster analysis, includes:
acquiring a user access mode and a user access service corresponding to the real-time flow data;
and dividing the users into groups of different types according to the user access mode, the user access service and a preset K-Means clustering algorithm, and determining the access behavior characteristics of the users, wherein each group has unique access behavior characteristics.
4. The method for dynamically balancing the flow of the cloud platform system according to claim 1, wherein the determining the corresponding trend of the access behavior according to the access behavior characteristics and the correlation between the access behaviors of the user determined on the user access data set by the preset association rule mining algorithm under different service scenarios comprises:
Determining access behaviors of different user groups according to the user access behavior feature analysis;
and determining the correlation between the access behaviors of different user groups in respective service scenes on the user access data set by using an Apriori association rule mining algorithm, and determining the corresponding access behavior change trend according to the correlation.
5. The method for dynamically balancing flow of a cloud platform system according to claim 1, wherein the step of inputting the flow variation trend and the access behavior variation trend into a decision tree regression prediction model, and determining whether a flow peak or an abnormal event exists according to an output of the decision tree regression prediction model, comprises:
Training a decision tree regression prediction model according to the historical sample data until an optimal prediction rule is formed, and inputting the flow change trend and the access behavior change trend into a set decision tree regression prediction model;
Judging whether a flow peak or an abnormal event exists according to the comparison relation between the predictive probability value output by the decision tree regression predictive model and the value of a preset threshold value.
6. The method for dynamically balancing flow of the cloud platform system according to claim 1, wherein when the flow peak or the abnormal event is detected, dynamically adjusting the resource allocation of the cloud platform system according to the flow change demand output by the decision tree regression prediction model, comprises:
when detecting that a flow peak or an abnormal event exists, determining key factors causing the abnormality according to the output of the decision tree regression prediction model;
And dynamically adjusting the resource allocation strategy of the cloud platform system according to the flow change requirement predicted by the decision tree regression model and the key factors causing the abnormality.
7. The method for dynamically balancing the flow of the cloud platform system according to claim 1, wherein the step of releasing the redundant resources until the standard configuration is restored after the real-time flow data of the cloud platform system falls back to the normal level comprises the steps of:
monitoring real-time flow data of the cloud platform system;
And gradually reducing the number of the computing nodes and the storage space after monitoring that the real-time flow data of the cloud platform system fall back to the normal level until the resource allocation of the system is completely restored to a preset standard state.
8. A cloud platform system flow dynamic balance processing device, the device comprising:
The flow change determining module is used for monitoring real-time flow data in the cloud platform system, performing time sequence model analysis on the real-time flow data in a set time period and determining a corresponding flow change trend;
The access behavior determining module is used for carrying out cluster analysis on the user access mode and the user access business corresponding to the real-time flow data, determining the access behavior characteristics of the user according to the result of the cluster analysis, and determining the corresponding access behavior change trend according to the access behavior characteristics and the correlation between the access behaviors of the user determined on the user access data set through a preset association rule mining algorithm under different business scenes;
The anomaly prediction module is used for inputting the flow change trend and the access behavior change trend into a set decision tree regression prediction model, judging whether a flow peak or an anomaly event exists according to the output of the decision tree regression prediction model, dynamically adjusting the resource allocation of the cloud platform system according to the flow change demand output by the decision tree regression prediction model when the flow peak or the anomaly event is detected, and releasing redundant resources until standard configuration is restored after the real-time flow data of the cloud platform system fall back to a normal level.
9. An electronic device comprising a memory, a processor and a computer program stored on the memory and executable on the processor, characterized in that the processor implements the steps of the cloud platform system traffic dynamic balancing processing method of any one of claims 1 to 7 when the program is executed by the processor.
10. A computer-readable storage medium, on which a computer program is stored, characterized in that the computer program, when being executed by a processor, implements the steps of the cloud platform system traffic dynamic balancing processing method according to any one of claims 1 to 7.
CN202411159175.7A 2024-08-22 2024-08-22 Cloud platform system traffic dynamic balancing processing method and device Active CN118694803B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202411159175.7A CN118694803B (en) 2024-08-22 2024-08-22 Cloud platform system traffic dynamic balancing processing method and device

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202411159175.7A CN118694803B (en) 2024-08-22 2024-08-22 Cloud platform system traffic dynamic balancing processing method and device

Publications (2)

Publication Number Publication Date
CN118694803A true CN118694803A (en) 2024-09-24
CN118694803B CN118694803B (en) 2024-12-13

Family

ID=92778299

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202411159175.7A Active CN118694803B (en) 2024-08-22 2024-08-22 Cloud platform system traffic dynamic balancing processing method and device

Country Status (1)

Country Link
CN (1) CN118694803B (en)

Cited By (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN119201411A (en) * 2024-11-28 2024-12-27 北京亿安天下科技股份有限公司 A dynamic computing resource scheduling method, system, device and storage medium
CN119629072A (en) * 2025-02-10 2025-03-14 中宇联云计算服务(上海)有限公司 A method and system for efficient processing of cloud data
CN119690636A (en) * 2024-09-29 2025-03-25 广州盘古传媒科技有限公司 Electronic commerce data analysis method and system based on cloud platform and electronic equipment
CN119829372A (en) * 2024-12-23 2025-04-15 江苏财经职业技术学院 Data sharing method of operation and maintenance audit system
CN119892738A (en) * 2024-12-24 2025-04-25 东方宇阳信息科技(北京)有限公司 Resource allocation management system based on data interconnection
CN120804497A (en) * 2025-09-12 2025-10-17 深圳市伊登软件有限公司 Intelligent prediction method and system based on big data analysis

Citations (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20190026761A1 (en) * 2013-06-13 2019-01-24 Flytxt B.V. Method and system for automated detection, classification and prediction of multi-scale, multidimensional trends
CN109711865A (en) * 2018-12-07 2019-05-03 恒安嘉新(北京)科技股份公司 A method of prediction is refined based on the mobile radio communication flow that user behavior excavates
CN113328987A (en) * 2021-04-09 2021-08-31 国网浙江省电力有限公司金华供电公司 Incremental learning flow anomaly detection method based on deep learning
CN117807425A (en) * 2024-03-01 2024-04-02 创略智造(河北)工业设计有限公司 Intelligent data analysis method and system
CN117976171A (en) * 2024-03-01 2024-05-03 江西省儿童医院 Medical resource optimal configuration system based on data analysis
CN117978515A (en) * 2024-02-21 2024-05-03 加禾科技(深圳)有限公司 Industrial computer network access control method and system
CN118363765A (en) * 2024-06-20 2024-07-19 湖南索思科技开发有限公司 Cloud resource automatic allocation system

Patent Citations (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20190026761A1 (en) * 2013-06-13 2019-01-24 Flytxt B.V. Method and system for automated detection, classification and prediction of multi-scale, multidimensional trends
CN109711865A (en) * 2018-12-07 2019-05-03 恒安嘉新(北京)科技股份公司 A method of prediction is refined based on the mobile radio communication flow that user behavior excavates
CN113328987A (en) * 2021-04-09 2021-08-31 国网浙江省电力有限公司金华供电公司 Incremental learning flow anomaly detection method based on deep learning
CN117978515A (en) * 2024-02-21 2024-05-03 加禾科技(深圳)有限公司 Industrial computer network access control method and system
CN117807425A (en) * 2024-03-01 2024-04-02 创略智造(河北)工业设计有限公司 Intelligent data analysis method and system
CN117976171A (en) * 2024-03-01 2024-05-03 江西省儿童医院 Medical resource optimal configuration system based on data analysis
CN118363765A (en) * 2024-06-20 2024-07-19 湖南索思科技开发有限公司 Cloud resource automatic allocation system

Non-Patent Citations (2)

* Cited by examiner, † Cited by third party
Title
王玲;: "移动网络用户行为挖掘模型及在E-Learning系统中的应用", 现代电子技术, no. 24, 15 December 2016 (2016-12-15) *
王瑞: "基于数据挖掘的电商女装个性化需求分析和预测研究 ——以YS公司为例", 《中国优秀硕士学位论文全文数据库 信息科技辑》, 15 May 2024 (2024-05-15) *

Cited By (8)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN119690636A (en) * 2024-09-29 2025-03-25 广州盘古传媒科技有限公司 Electronic commerce data analysis method and system based on cloud platform and electronic equipment
CN119201411A (en) * 2024-11-28 2024-12-27 北京亿安天下科技股份有限公司 A dynamic computing resource scheduling method, system, device and storage medium
CN119201411B (en) * 2024-11-28 2025-02-11 北京亿安天下科技股份有限公司 Dynamic computing power resource scheduling method, system, equipment and storage medium
CN119829372A (en) * 2024-12-23 2025-04-15 江苏财经职业技术学院 Data sharing method of operation and maintenance audit system
CN119829372B (en) * 2024-12-23 2025-08-12 江苏财经职业技术学院 A data sharing method for operation and maintenance audit system
CN119892738A (en) * 2024-12-24 2025-04-25 东方宇阳信息科技(北京)有限公司 Resource allocation management system based on data interconnection
CN119629072A (en) * 2025-02-10 2025-03-14 中宇联云计算服务(上海)有限公司 A method and system for efficient processing of cloud data
CN120804497A (en) * 2025-09-12 2025-10-17 深圳市伊登软件有限公司 Intelligent prediction method and system based on big data analysis

Also Published As

Publication number Publication date
CN118694803B (en) 2024-12-13

Similar Documents

Publication Publication Date Title
CN118694803A (en) Cloud platform system traffic dynamic balancing processing method and device
US10645022B2 (en) Methods and systems providing a scalable process for anomaly identification and information technology infrastructure resource optimization
US20210314231A1 (en) Capacity Management of Computing Resources Based on Time Series Analysis
US11449809B2 (en) Application capacity forecasting
CN117768469A (en) Cloud service management method and system based on big data
Pethuraj et al. Analyzing QoS factor in 5 G communication using optimized data communication techniques for E-commerce applications
CN109034912B (en) Information pushing system for electronic commerce operation with audience screening function
CN118394713A (en) Log data processing method, device, equipment, storage medium and program product
US20210304102A1 (en) Automatically allocating network infrastructure resource usage with key performance indicator
Park et al. Combining genetic algorithms and bayesian neural networks for resource usage prediction in multi-tenant container environments
CA3241380A1 (en) Commodity information pushing method, device and system
CN107392259A (en) The method and apparatus for building unbalanced sample classification model
CN119025539A (en) A data interaction system based on artificial intelligence
JP5646442B2 (en) Analysis apparatus and analysis method
CN118735569A (en) A method and system for managing precision marketing data resources in digital trade
CN113656702A (en) User behavior prediction method and device
US12259936B1 (en) Method and system for providing customized experience to a user profile
CN119583552B (en) Information system dynamic load balancing and maintaining method based on cloud computing
CN113779189A (en) Communication request flow prediction method and device
CN111768306A (en) Risk identification method and system based on intelligent data analysis
WO2025074425A1 (en) System and method for selecting anomaly detection technique
KR102448702B1 (en) Edge service extension control system and its control method
CN118822554A (en) User complaint prediction method, device, storage medium and program product
CN119226375A (en) Method, device, equipment and storage medium for processing customer data
CN118279059A (en) Data pushing method, device and equipment

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
GR01 Patent grant
GR01 Patent grant