def __init__(self, collector_config, task):
    self.collector_config = collector_config
    self.task = task
    self.url = "http://%s:%d%s" % (
      task.host, task.port,
      self.collector_config.config.get(task.job.cluster.service.name, "metric_url"))
    self.need_analyze = collector_config.services[task.job.cluster.service.name].need_analyze
dataset/ETHPy150Open XiaoMi/minos/owl/collector/management/commands/collect.py/MetricSource.__init__/original