1.一种基于分布式计算的数据处理方法,其特征在于,该方法包括以下步骤:
S1、实时调整业务范围内所有执行单元的状态;
S2、将业务拆分为N个子任务,分配给不同执行单元执行;
S3、任务完成后,对执行单元进行评分;
S4、业务完成后,返回S1步骤继续等待下一次业务;
在S1中,对执行单元的状态调整步骤如下:
S101、通过重量传感器来采集各执行单元所在区域的重量信息,实时计算当前采集重量值与上一时刻所采集重量值的差值,判断该差值是否处于重量误差区间,处于误差区间,则不做处理,直接进入S103步骤;不处于误差区间,则标记对应执行单元,进入S102步骤;
S102、利用数学建模的方法为每个执行单元建立一幅背景图像,该背景图像内没有执行对象存在,启动对应摄像头对被标记的执行单元所在区域进行拍照,采集当前图像,将两张图像对应像素点的灰度值进行相减,取绝对值后得到差分图像,公式如下:Z
式中,Z
设定阈值X,对差分图像所有像素点进行二值化处理,得到二值化图像,灰度值255的点为前景点,灰度值0的点为背景点;公式如下:式中,Q
对图像Q
S103、通过安装在执行对象操控的计算机上的测试软件来判断对应执行单元是否被分配任务,任务包括主动任务和被动任务,只有分配到被动任务的执行单元才会进行状态改变,被动任务的分配只针对状态为空闲状态的执行单元,将分配到被动任务的执行单元状态由空闲状态更改为忙碌状态;将测试软件检测到任务已提交的执行单元状态由忙碌状态更改为空闲状态;将测试软件检测到任务未提交且执行单元所在区域内不存在执行对象的执行单元状态由忙碌状态更改为异常状态;
在S2中,业务拆分为子任务以及子任务的分配步骤如下:
S201、将需要处理的业务按照执行方式进行拆分,拆分为计算机能够独立执行并响应的主动任务和需要执行对象协调才能完成的被动任务;
S202、主动任务交由状态为离线状态的执行单元去执行;
S203、被动任务根据业务需求,继续划分为不同优先级的分任务,按照优先级的高低顺序,依次交由状态为空闲状态且高状态值的执行单元去执行;
在S3中,对执行单元的评分是指计算该执行单元的状态值,状态值包括固定状态值和浮动状态值;步骤如下:S301、首先,将执行对象的鼠标位移速度、键盘输入速度和任务处理速度代入公式中计算出对应执行单元的固定状态值;公式如下:式中,ZTZ
S302、根据执行单元距离上次执行任务的时间计算出浮动状态值,将固定状态值与浮动状态值求和,计算出执行单元的状态值,公式如下:式中,ZTZ为执行单元的状态值,ZTZ
2.根据权利要求1所述的一种基于分布式计算的数据处理方法,其特征在于:当执行单元在执行被动任务时,重量差值变化为负数且对应执行单元所在区域不存在执行对象,执行对象已经离开对应执行单元所在区域,将对应执行单元状态由忙碌状态更改为异常状态,并警示工作人员及时处理。
3.一种基于分布式计算的数据处理系统,应用于如权利要求1所述的一种基于分布式计算的数据处理方法,其特征在于,该系统包括:数据采集模块、数据处理模块、功能调用模块和数据存储模块;
所述数据采集模块用于采集业务范围内所有执行对象的重量信息、图像信息和输入信息,将这些信息发送至数据处理模块;所述数据处理模块根据执行对象的重量信息、图像信息和输入信息设定对应执行单元的状态,根据执行对象的输入信息计算对应执行单元的状态值,对不同状态的执行单元分配不同类型的任务,对不同状态值的执行单元分配不同优先级的任务;所述功能调用模块用于调用重量传感器、摄像头和测试软件;所述数据存储模块用于对所有信息进行备份存储。
4.根据权利要求3所述的一种基于分布式计算的数据处理系统,其特征在于:所述数据采集模块包括重量信息采集单元、图像信息采集单元和输入信息采集单元;
所述重量信息采集单元用于采集执行对象的重量信息,通过重量传感器进行重量信息收集,当执行对象离开或进入对应执行单元所在区域时,重量信息产生变化;
所述图像信息采集单元用于采集执行对象的图像信息,通过安装在执行单元所在区域的摄像头进行图像信息收集,当执行对象处于对应执行单元所在区域时,摄像头能够拍摄到执行对象;
所述输入信息采集单元用于采集执行对象的输入信息以及检测执行对象所对应的执行单元是否被分配任务,通过安装在执行对象操控的计算机上的测试软件来进行输入信息收集,输入信息包括鼠标位移速度、键盘输入速度、任务处理速度和距离上次执行任务的时间。
5.根据权利要求3所述的一种基于分布式计算的数据处理系统,其特征在于:所述数据处理模块包括状态管理单元、状态值计算单元和任务分配单元;
所述状态管理单元用于对业务范围内所有执行单元的状态进行管理,根据不同执行对象的重量信息、图像信息和输入信息更改对应执行单元的状态;执行单元的状态包括离线状态、空闲状态、忙碌状态和异常状态,状态更改包括:由离线状态到空闲状态、由空闲状态到忙碌状态、由忙碌状态到空闲状态、由忙碌状态到异常状态和由空闲状态到离线状态;
所述状态值计算单元用于计算出对应执行单元的状态值,状态值决定对应执行单元执行任务的时效性,对应执行单元状态值越高,执行任务效率越高;
所述任务分配单元用于对业务进行子任务划分和调度;将需要被处理的业务划分为不同类型的子任务,子任务类型包括主动任务和被动任务:主动任务是指能够被计算机识别并自动执行和响应,不需要执行对象任何操作的任务,将主动任务交由状态为离线状态的执行单元去执行;被动任务是指不能完全被计算机识别,需要执行对象协调操作的任务,被动任务按照业务需求的不同划分为不同优先级的分任务,优先级包括高和低,将被动任务中不同优先级的分任务交由不同状态值的空闲状态执行单元去执行;所有分配操作进行日志记录。
6.根据权利要求3所述的一种基于分布式计算的数据处理系统,其特征在于:所述功能调用模块用于调用对应执行单元所在区域的重量传感器,采集执行对象的重量信息;调用对应执行单元所在区域的摄像头,采集执行对象的图像信息;调用执行对象操控的计算机上的测试软件,采集执行对象的输入信息。
7.根据权利要求3所述的一种基于分布式计算的数据处理系统,其特征在于:所述数据存储模块用于将采集信息、状态信息和分配日志信息存入数据库,以供溯源操作。