kapacitor :指定python udf时不打开http端口。

Question

我试图从这个URL https://www.youtube.com/watch?v=LL8g4qiBCNo中了解kapacitor用户定义函数(udf)。

当我没有指定python时，kapacitor将在http端口9092上启动和侦听。

我在kapacitor.conf中的udf部分看起来像

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

我的python (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。

Answer 1

我解决了上述问题，将

print >> sys.stdout

使用

print >> sys.stderr