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

switch report from kafka to http-post

Browse Source
This commit is contained in:
Newnius 2020-07-08 20:17:10 +08:00
parent 86aaeead30
commit eafa087980
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
agent.py
View File

@ -6,7 +6,6 @@ import subprocess
import json import json
from xml.dom.minidom import parse from xml.dom.minidom import parse
import xml.dom.minidom import xml.dom.minidom
from kafka import KafkaProducer
import multiprocessing import multiprocessing
import psutil import psutil
import math import math
@ -18,11 +17,12 @@ from urllib import parse
import random import random
import string import string
from pathlib import Path from pathlib import Path
import requests
ClientID = os.getenv('ClientID', 1) ClientID = os.getenv('ClientID', 1)
ClientHost = os.getenv('ClientHost', "localhost") ClientHost = os.getenv('ClientHost', "localhost")
ClientExtHost = os.getenv('ClientExtHost', "localhost") ClientExtHost = os.getenv('ClientExtHost', "localhost")
KafkaBrokers = os.getenv('KafkaBrokers', 'localhost:9092').split(',') ReportAddress = os.getenv('ReportAddress', "http://yao-scheduler:8080/?action=agent_report")
RackID = os.getenv('RackID', "default") RackID = os.getenv('RackID', "default")
DomainID = os.getenv('DomainID', "default") DomainID = os.getenv('DomainID', "default")
@ -514,9 +514,14 @@ def report_msg(stats):
data = json.dumps(post_fields) data = json.dumps(post_fields)
url = ReportAddress
params = {'data': data}
result = requests.post(url, data=params)
'''
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)
result = future.get(timeout=5) result = future.get(timeout=5)
'''
def listener(): def listener():