

def handle(self, key, value):
    return_dict = {
        'info-test': value,
        'appid': 'someapp',
    }
    self._send_to_kafka(return_dict)
    self.redis_conn.delete(key)

dataset/ETHPy150Open istresearch/scrapy-cluster/redis-monitor/tests/tests_online.py CustomMonitor.handle/original