#from __future__ import absolute_import
import importlib
import argparse,json
mod = importlib.import_module("scrapy_cluster.kafka-monitor.kafka_monitor")
KafkaMonitor=mod.KafkaMonitor

KAFKA_HOSTS = 'kafka.1.svc:9092'
kafka_monitor = KafkaMonitor('localsettings.py')

kafka_monitor.setup(level='INFO', log_file='INFO',
                    json='INFO')
json_req='{"url": "http://istresearch.com", "appid":"testapp", "crawlid":"ABC123"}'
try:
    parsed = json.loads(json_req)
except ValueError:
    kafka_monitor.logger.info("JSON failed to parse")

kafka_monitor.feed(parsed)

42ad16ada7b2f554c7f239405e9a426f0ef7df1e
<mask token>

<mask token>
kafka_monitor.setup(level='INFO', log_file='INFO', json='INFO')
<mask token>
try:
    parsed = json.loads(json_req)
except ValueError:
    kafka_monitor.logger.info('JSON failed to parse')
kafka_monitor.feed(parsed)

<mask token>
mod = importlib.import_module('scrapy_cluster.kafka-monitor.kafka_monitor')
KafkaMonitor = mod.KafkaMonitor
KAFKA_HOSTS = 'kafka.1.svc:9092'
kafka_monitor = KafkaMonitor('localsettings.py')
kafka_monitor.setup(level='INFO', log_file='INFO', json='INFO')
json_req = (
    '{"url": "http://istresearch.com", "appid":"testapp", "crawlid":"ABC123"}')
try:
    parsed = json.loads(json_req)
except ValueError:
    kafka_monitor.logger.info('JSON failed to parse')
kafka_monitor.feed(parsed)

import importlib
import argparse, json
mod = importlib.import_module('scrapy_cluster.kafka-monitor.kafka_monitor')
KafkaMonitor = mod.KafkaMonitor
KAFKA_HOSTS = 'kafka.1.svc:9092'
kafka_monitor = KafkaMonitor('localsettings.py')
kafka_monitor.setup(level='INFO', log_file='INFO', json='INFO')
json_req = (
    '{"url": "http://istresearch.com", "appid":"testapp", "crawlid":"ABC123"}')
try:
    parsed = json.loads(json_req)
except ValueError:
    kafka_monitor.logger.info('JSON failed to parse')
kafka_monitor.feed(parsed)

#from __future__ import absolute_import
import importlib
import argparse,json
mod = importlib.import_module("scrapy_cluster.kafka-monitor.kafka_monitor")
KafkaMonitor=mod.KafkaMonitor

KAFKA_HOSTS = 'kafka.1.svc:9092'
kafka_monitor = KafkaMonitor('localsettings.py')

kafka_monitor.setup(level='INFO', log_file='INFO',
                    json='INFO')
json_req='{"url": "http://istresearch.com", "appid":"testapp", "crawlid":"ABC123"}'
try:
    parsed = json.loads(json_req)
except ValueError:
    kafka_monitor.logger.info("JSON failed to parse")

kafka_monitor.feed(parsed)
