Я пытаюсь узнать о пользовательских функциях 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