ops/datacollect
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix bug

Browse Source
This commit is contained in:
root 2019-08-12 17:28:37 +08:00
parent 17b52f943b
commit d6a66ccea6
6 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

BIN
config/__pycache__/config.cpython-36.pyc
View File

Binary file not shown.

2
config/config.py
View File

@ -14,4 +14,4 @@ if not is_debug:
(1016, 6001, 'shop_1016'), (1016, 6001, 'shop_new_1016'), (1016, 6001, 'tap_1016'), (1016, 6001, 'shop_1016'), (1016, 6001, 'shop_new_1016'), (1016, 6001, 'tap_1016'),
(1016, 6001, 'tap_new_1016'), (2001, 6001, 'tap_2001'), (2001, 6001, 'tap_new_2001')) (1016, 6001, 'tap_new_1016'), (2001, 6001, 'tap_2001'), (2001, 6001, 'tap_new_2001'))
else: else:
event_list = ((1001, 6001, 'items_produce'), (1001, 6001, 'items_consum'),(1001, 6001, 'share_map')) event_list = ((1004, 6001, 'items_produce'), (1004, 6001, 'items_consum'),(1004, 6001, 'share_map'))

BIN
mytask/__pycache__/tasks_base.cpython-36.pyc
View File

Binary file not shown.

BIN
mytask/__pycache__/tga.cpython-36.pyc
View File

Binary file not shown.

1
mytask/tga.py
View File

@ -349,6 +349,7 @@ class GetFromTga:
if line: if line:
try: try:
temp['num'], temp['u_num'], temp['activity_id_str'] = line temp['num'], temp['u_num'], temp['activity_id_str'] = line
print(f"123 {temp}")
temp['activity_id'] = activity_ids.get(temp['activity_id_str']) temp['activity_id'] = activity_ids.get(temp['activity_id_str'])
self.write_tga_files(temp) self.write_tga_files(temp)
except Exception: except Exception:

11
ops/scripts.py
View File

@ -1,6 +1,6 @@
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
import pymongo import pymongo
import pdb
def get_activity_ids(): def get_activity_ids():
# get data from mongodb # get data from mongodb
@ -9,12 +9,9 @@ def get_activity_ids():
myclient = pymongo.MongoClient("mongodb://10.10.5.6:27017/") myclient = pymongo.MongoClient("mongodb://10.10.5.6:27017/")
mydb = myclient["garfield-production"] mydb = myclient["garfield-production"]
mycol = mydb["system_dics"] mycol = mydb["system_dics"]
myquery = {type: 'share_cfg', 'deleted': False} myquery = {'type': 'share_cfg', 'deleted': False}
out_area = {'key': 1, 'value': 1, '_id': 0} out_area = {'key': 1, 'value': 1, '_id': 0}
all = [] all = {}
for x in mycol.find(myquery, out_area): for x in mycol.find(myquery, out_area):
temp = {} all[x['key']]=x['value']
a, b = x
temp[a] = b
all.append(temp)
return all return all