YAO/YAO-agent
1
0
Fork 0
mirror of https://github.com/newnius/YAO-agent.git synced 2025-06-07 22:01:55 +00:00
Code Issues Releases Wiki Activity

ignore error msg

Browse Source
This commit is contained in:
Newnius 2020-07-08 20:39:54 +08:00
parent 7dbc41fd81
commit 9fcf5863e8
2 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
agent.py
View File

@ -514,9 +514,12 @@ def report_msg(stats):
data = json.dumps(post_fields) data = json.dumps(post_fields)
url = ReportAddress try:
params = {'data': data} url = ReportAddress
result = requests.post(url, data=params) params = {'data': data}
result = requests.post(url, data=params)
except Exception as e:
pass
''' '''
producer = KafkaProducer(bootstrap_servers=KafkaBrokers) producer = KafkaProducer(bootstrap_servers=KafkaBrokers)
future = producer.send('yao', value=data.encode(), partition=0) future = producer.send('yao', value=data.encode(), partition=0)

9
mock.py
View File

@ -123,9 +123,12 @@ def report(ClientID):
} }
data = json.dumps(post_fields) data = json.dumps(post_fields)
url = ReportAddress try:
params = {'data': data} url = ReportAddress
result = requests.post(url, data=params) params = {'data': data}
result = requests.post(url, data=params)
except Exception as e:
pass
''' '''
producer = KafkaProducer(bootstrap_servers=KafkaBrokers) producer = KafkaProducer(bootstrap_servers=KafkaBrokers)
future = producer.send('yao', value=data.encode(), partition=0) future = producer.send('yao', value=data.encode(), partition=0)