Loading src/telemetry_frontend/backend/service/KafkaProducerService.py +8 −6 Original line number Diff line number Diff line Loading @@ -12,36 +12,38 @@ # See the License for the specific language governing permissions and # limitations under the License. from KafkaProducerServiceImpl import KafkaProducerServiceImpl from .KafkaProducerServiceImpl import KafkaProducerServiceImpl class KafkaProducerService: """ Class to control Kafka producer functionality. """ def __init__(self): kafka_configs = self.generate_kafka_configurations() kafka_configs = self.generate_kafka_configs() self.bootstrap_servers = kafka_configs['bootstrap_servers'] self.node_exporter_endpoint = kafka_configs['node_exporter_endpoint'] self.kafka_topic = kafka_configs['kafka_topic'] self.run_duration = kafka_configs['run_duration'] self.fetch_interval = kafka_configs['fetch_interval'] def generate_kafka_configurations(self): def generate_kafka_configs(self): # define the function to get every attribute """ Method to generate Kafka configurations """ create_kafka_configuration = { create_kafka_configs = { 'bootstrap_servers' : '127.0.0.1:9092', # Kafka broker address - Replace with your Kafka broker address 'node_exporter_endpoint' : 'http://10.152.183.231:9100/metrics', # Node Exporter metrics endpoint - Replace with your Node Exporter endpoint 'kafka_topic' : 'metric-data', # Kafka topic to produce to 'run_duration' : 20, # Total duration to execute the producer 'fetch_interval' : 4 # Time between two fetch requests } return create_kafka_configuration return create_kafka_configs def run_producer(self): """ Method to create KafkaProducerServiceImpl object and start producer thread. Method to create KafkaProducerServiceImpl object and start producer. """ # Create NodeExporterProducer object and run start_producer_thread producer = KafkaProducerServiceImpl(self.bootstrap_servers, self.node_exporter_endpoint, Loading Loading
src/telemetry_frontend/backend/service/KafkaProducerService.py +8 −6 Original line number Diff line number Diff line Loading @@ -12,36 +12,38 @@ # See the License for the specific language governing permissions and # limitations under the License. from KafkaProducerServiceImpl import KafkaProducerServiceImpl from .KafkaProducerServiceImpl import KafkaProducerServiceImpl class KafkaProducerService: """ Class to control Kafka producer functionality. """ def __init__(self): kafka_configs = self.generate_kafka_configurations() kafka_configs = self.generate_kafka_configs() self.bootstrap_servers = kafka_configs['bootstrap_servers'] self.node_exporter_endpoint = kafka_configs['node_exporter_endpoint'] self.kafka_topic = kafka_configs['kafka_topic'] self.run_duration = kafka_configs['run_duration'] self.fetch_interval = kafka_configs['fetch_interval'] def generate_kafka_configurations(self): def generate_kafka_configs(self): # define the function to get every attribute """ Method to generate Kafka configurations """ create_kafka_configuration = { create_kafka_configs = { 'bootstrap_servers' : '127.0.0.1:9092', # Kafka broker address - Replace with your Kafka broker address 'node_exporter_endpoint' : 'http://10.152.183.231:9100/metrics', # Node Exporter metrics endpoint - Replace with your Node Exporter endpoint 'kafka_topic' : 'metric-data', # Kafka topic to produce to 'run_duration' : 20, # Total duration to execute the producer 'fetch_interval' : 4 # Time between two fetch requests } return create_kafka_configuration return create_kafka_configs def run_producer(self): """ Method to create KafkaProducerServiceImpl object and start producer thread. Method to create KafkaProducerServiceImpl object and start producer. """ # Create NodeExporterProducer object and run start_producer_thread producer = KafkaProducerServiceImpl(self.bootstrap_servers, self.node_exporter_endpoint, Loading