kapacitor: не открывается порт http, когда указан питон udf - PullRequest
Новая
       34

kapacitor: не открывается порт http, когда указан питон udf

0 голосов
/ 11 сентября 2018

Я пытаюсь узнать о пользовательских функциях kapacitor (udf) по этому URL-адресу https://www.youtube.com/watch?v=LL8g4qiBCNo

kapacitor запускается и прослушивает http-порт 9092, когда я не указываю uthon для python.

Мой [udf] раздел в kapacitor.conf выглядит так: 

[udf]
[udf.functions]
    [udf.functions.geoSum]
      prog = "/usr/bin/python"
      args = ["-u", "/tmp/geo.py"]
      timeout = "20s"

Мой python udf (geo.py) выглядит следующим образом: 

import sys
from agent import Agent, Handler
import udf_pb2
class GeoSum(Handler):
    def __init__(self):
                self._field = ''
                self.size = 0
    def info(self):
        response = udf_pb2.Response()
        response.info.wants = udf_pb2.STREAM
        response.info.provides = udf_pb2.STREAM
        response.info.options['field'].valueTypes.append(udf_pb2.STRING)
        response.info.options['size'].valueTypes.append(udf_pb2.INT)
        response.info.options['magic'].valueTypes.extend([
              udf_pb2.INT,
              udf_pb2.DOUBLE,
              udf_pb2.DURATION
        ])
        return response

if __name__ == '__main__':
    agent = Agent()
    handler = GeoSum()
    agent.handler = handler

    print >> sys.stdout, "Starting GeoSum ..."
    agent.start()
    agent.wait()
    print >> sys.stdout, "Stoping GeoSum ..."

С указанным выше разделом udf kapacitor непрослушивать порт http 9092

1 Ответ

0 голосов
/ 11 сентября 2018

Я решил вышеупомянутую проблему, заменив вхождения 

print >> sys.stdout

на 

print >> sys.stderr
...