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