#!/usr/bin/env python
import clone_repos,os, signal
from pykafka import KafkaClient
import pickle, process_sonar, process_es,kafkaConsumer
import os, sys,signal
sys.path.append(os.path.abspath("../config"))
import configparams

def process_es_update(messages,config):
    for message in messages:
        if message is not None:
            processed_sonar_data = pickle.loads(message.value)
            print(processed_sonar_data)
            process_es.automate_processes(config,processed_sonar_data)
        else:
            pass

if __name__ == "__main__":
    parsed = configparams._parse_commandline()
    config = configparams.main(parsed)
    messages = kafkaConsumer._get_balanced_consumer(config)
    print(messages)
    process_es_update(messages,config)

c580f3b78fdcd26383dc744f4f7907560d3f9677
<mask token>

<mask token>


def process_es_update(messages, config):
    for message in messages:
        if message is not None:
            processed_sonar_data = pickle.loads(message.value)
            print(processed_sonar_data)
            process_es.automate_processes(config, processed_sonar_data)
        else:
            pass


<mask token>

<mask token>
sys.path.append(os.path.abspath('../config'))
<mask token>


def process_es_update(messages, config):
    for message in messages:
        if message is not None:
            processed_sonar_data = pickle.loads(message.value)
            print(processed_sonar_data)
            process_es.automate_processes(config, processed_sonar_data)
        else:
            pass


if __name__ == '__main__':
    parsed = configparams._parse_commandline()
    config = configparams.main(parsed)
    messages = kafkaConsumer._get_balanced_consumer(config)
    print(messages)
    process_es_update(messages, config)

import clone_repos, os, signal
from pykafka import KafkaClient
import pickle, process_sonar, process_es, kafkaConsumer
import os, sys, signal
sys.path.append(os.path.abspath('../config'))
import configparams


def process_es_update(messages, config):
    for message in messages:
        if message is not None:
            processed_sonar_data = pickle.loads(message.value)
            print(processed_sonar_data)
            process_es.automate_processes(config, processed_sonar_data)
        else:
            pass


if __name__ == '__main__':
    parsed = configparams._parse_commandline()
    config = configparams.main(parsed)
    messages = kafkaConsumer._get_balanced_consumer(config)
    print(messages)
    process_es_update(messages, config)

#!/usr/bin/env python
import clone_repos,os, signal
from pykafka import KafkaClient
import pickle, process_sonar, process_es,kafkaConsumer
import os, sys,signal
sys.path.append(os.path.abspath("../config"))
import configparams

def process_es_update(messages,config):
    for message in messages:
        if message is not None:
            processed_sonar_data = pickle.loads(message.value)
            print(processed_sonar_data)
            process_es.automate_processes(config,processed_sonar_data)
        else:
            pass

if __name__ == "__main__":
    parsed = configparams._parse_commandline()
    config = configparams.main(parsed)
    messages = kafkaConsumer._get_balanced_consumer(config)
    print(messages)
    process_es_update(messages,config)
