标签：node 聚合 python each 树形 values atom handle data
思路：
1、把所有节点递归添加到一个集合里，每个对象是一个字典数据，规定每个对象的id和父id（注意递归添加的顺序）
2、处理集合，使用倒序把子节点的数据聚合给父节点（for倒序循环，判断当前节点（父节点）的数据不存在，内层遍历集合所有节点，把父id是当前节点id的节点拿出放到新集合处理）
3、循环完成后，最上层节点数据就聚合Ok，遍历集合，根据id拿自己要的节点数据就好了
因为我遍历的集合存在时间不统一，索引长度也就不一样。另加判断处理。
代码：
递归添加节点数据到集合（首先拿到第二层节点）
data = [] # 表格、雷达图和线状图所需数据 格式：[{"aaa":"1","bbb":"2".......}]
x_values = [] # 线状图x坐标集，第二层节点的日期集合
y_values = [] # 线状图y坐标集，第二层节点的数据集合
sql
sql
sql
sql
children_nodes = db.query_sql(query_childrens_sql % target_id)
all_node_data = []
getAll_node_data_to_list(children_nodes,all_node_data,sql_queryAtom_all_details,query_childrens_sql,query_parent_sql,start_time,end_time) #递归方法
#这样就得到二级节点及以下所有节点的对象集合，递归方法看最下面
for i in range(len(all_node_data)):
# 从集合最后一项向前处理数据
if len(all_node_data[len(all_node_data)-i-1]["atom_data"]) == 0:
id = all_node_data[len(all_node_data)-i-1]["id"]
algorithm_name = all_node_data[len(all_node_data)-i-1]["algorithm_name"] # 拿到父节点的聚合算法
handle_data = []
for node_data in all_node_data:
if node_data["parent_node_id"] == id:
handle_data.append(node_data)
if len(handle_data) == 1:
handle_data1 = handle_data[0]
all_node_data[len(all_node_data)-i-1]["atom_data"] = handle_data1["atom_data"]
if len(handle_data) == 2:
length_list = []
handle_data1 = handle_data[0]
length_list.append(len(handle_data1["atom_data"]))
handle_data2 = handle_data[1]
length_list.append(len(handle_data2["atom_data"]))
for j in range(min(length_list)):
dict_data = {}
dict_data['clock'] = handle_data1["atom_data"][j]['clock']
if int(algorithm_name) == 2: # 平均值计算
dict_data['value'] = (float(handle_data1["atom_data"][j]['value']) + float(handle_data2["atom_data"][j]['value']))/2
if int(algorithm_name) == 3: # 最大值计算
details_data_list = []
details_data_list.append(float(handle_data1["atom_data"][j]['value']))
details_data_list.append(float(handle_data2["atom_data"][j]['value']))
dict_data['value'] = max(details_data_list)
if int(algorithm_name) == 4:
details_data_list = []
details_data_list.append(float(handle_data1["atom_data"][j]['value']))
details_data_list.append(float(handle_data2["atom_data"][j]['value']))
dict_data['value'] = min(details_data_list)
dict_data['value'] = float(handle_data1["atom_data"][j]['value']) + float(handle_data2["atom_data"][j]['value'])
if int(algorithm_name) == 11:
dict_data['value'] = float(handle_data1["atom_data"][j]['value']) * float(handle_data2["atom_data"][j]['value'])
all_node_data[len(all_node_data)-i-1]["atom_data"].append(dict_data)
列举了1~2个子节点的运算，多节点请照猫画虎
得到处理完成的list集合，接下来拿数据就行了
for node_data in all_node_data:
if node_data['parent_node_id'] == target_id:
atom_data = node_data['atom_data']
each_x_values = []
each_y_values = []
for each_data in atom_data:
timeArray = time.localtime(each_data['clock'] + 8*60*60)
otherStyleTime = time.strftime("%Y--%m--%d %H:%M:%S", timeArray)
each_x_values.append(otherStyleTime)
each_y_values.append(float(each_data['value']))
avg_data = sum(each_y_values) / len(each_y_values)
attack_score += round(avg_data,3)
attack_score_list.append(round(avg_data,3))
dict_data_values[node_data['assess_name']] = round(avg_data,3)
x_values.append(each_x_values)
# 线型图y轴数值归一化
normalization_y_values = []
for i in range(len(each_y_values)):
if max(each_y_values) == 0:
normalization_y_values.append(0)
else:
normalization_y_values.append((each_y_values[i]-min(each_y_values))/(max(each_y_values)-min(each_y_values)))
y_values.append(normalization_y_values)
data.append(dict_data_values)
以下是递归添加数据的方法：
def getAll_node_data_to_list(children_nodes,all_node_data,sql_queryAtom_all_details,query_childrens_sql,query_parent_sql,start_time,end_time):
if len(children_nodes) > 0:
for children_node in children_nodes:
each_node_data = {}
each_node_data["id"] = children_node["id"]
each_node_data["algorithm_name"] = children_node["algorithm_name"]
each_node_data["assess_name"] = children_node["assess_name"]
# 判断是否最后一层节点，我的规则是绑定原子数据的就为最后一层，直接把数据添加到对象的atom_data中，这样就能保证最底层节点存在数据，聚合的时候父节点可以拿这些数据进行处理
if children_node["atom_id"] == "" or children_node["atom_id"] is None:
each_node_data["atom_data"] = []
else:
params = (children_node["atom_id"] or "", start_time or "", end_time or "")
atom_data = db.query_sql(sql_queryAtom_all_details % params)
each_node_data["atom_data"] = atom_data
each_node_data["parent_node_id"] = db.query_sql(query_parent_sql % children_node["id"])[0]["pid"]
all_node_data.append(each_node_data)
children_nodes = db.query_sql(query_childrens_sql % children_node["target_id"])
getAll_node_data_to_list(children_nodes,all_node_data,sql_queryAtom_all_details,query_childrens_sql,query_parent_sql,start_time,end_time,)
sql语句就不放这了，自己写吧。啊哈哈哈哈哈哈哈哈哈哈哈哈
标签：node,聚合,python,each,树形,values,atom,handle,data 来源： https://www.cnblogs.com/yanzhen108/p/15737120.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。