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

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

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

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

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

Мой питон 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 ответ

Решение

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

print >> sys.stdout

с

print >> sys.stderr
Другие вопросы по тегам