From f5fbf46d82e4ea5325e89459c5ad9f753f1ca66b Mon Sep 17 00:00:00 2001 From: Aravinda VK Date: Mon, 1 Aug 2016 17:16:50 +0530 Subject: eventsapi: Python library for gf_event Python library to emit Events from Geo-replication or any other Python apps running in storage nodes. Add $LIBEXEC/glusterfs/events to Python path to use gf_event gf_event(event_type, **kwargs) For example, sys.path.insert(1, "LIBEXECDIR/glusterfs") from events.gf_event import gf_event from events import eventtypes gf_event(eventtypes.GEOREP_FAULTY, volname="gv1", slaveuser="root", slavehost="node1", slavevol="gv2") Errors will be logged in $LOGDIR/glusterfs/events.log BUG: 1362144 Change-Id: I2af2bd77f9961975e4387006b9e99e4543e12b57 Signed-off-by: Aravinda VK Reviewed-on: http://review.gluster.org/15063 Smoke: Gluster Build System NetBSD-regression: NetBSD Build System CentOS-regression: Gluster Build System Reviewed-by: Samikshan Bairagya Reviewed-by: Prashanth Pai --- events/eventskeygen.py | 6 +++++- events/src/Makefile.am | 5 +++-- events/src/gf_event.py | 48 ++++++++++++++++++++++++++++++++++++++++++++++++ 3 files changed, 56 insertions(+), 3 deletions(-) create mode 100644 events/src/gf_event.py (limited to 'events') diff --git a/events/eventskeygen.py b/events/eventskeygen.py index bccb91a3a64..7357d8e84a3 100644 --- a/events/eventskeygen.py +++ b/events/eventskeygen.py @@ -78,4 +78,8 @@ if gen_header_type == "PY_HEADER": f.write("all_events = [\n") for ev in keys: f.write(' "{0}",\n'.format(ev)) - f.write("]\n") + + f.write("]\n\n") + + for idx, ev in enumerate(keys): + f.write("{0} = {1}\n".format(ev.replace("EVENT_", ""), idx)) diff --git a/events/src/Makefile.am b/events/src/Makefile.am index 8b2150e3aa9..423bc8891fb 100644 --- a/events/src/Makefile.am +++ b/events/src/Makefile.am @@ -1,6 +1,6 @@ noinst_PYTHON = $(top_srcdir)/events/eventskeygen.py EXTRA_DIST = glustereventsd.py __init__.py eventsapiconf.py.in \ - handlers.py utils.py peer_eventsapi.py eventsconfig.json + handlers.py utils.py peer_eventsapi.py eventsconfig.json gf_event.py BUILT_SOURCES = eventtypes.py CLEANFILES = eventtypes.py @@ -10,7 +10,8 @@ eventspeerscriptdir = $(libexecdir)/glusterfs eventsconfdir = $(sysconfdir)/glusterfs eventsconf_DATA = eventsconfig.json -events_PYTHON = __init__.py eventsapiconf.py eventtypes.py handlers.py utils.py +events_PYTHON = __init__.py eventsapiconf.py eventtypes.py handlers.py \ + utils.py gf_event.py events_SCRIPTS = glustereventsd.py eventspeerscript_SCRIPTS = peer_eventsapi.py diff --git a/events/src/gf_event.py b/events/src/gf_event.py new file mode 100644 index 00000000000..0924a65dddb --- /dev/null +++ b/events/src/gf_event.py @@ -0,0 +1,48 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- +# +# Copyright (c) 2016 Red Hat, Inc. +# This file is part of GlusterFS. +# +# This file is licensed to you under your choice of the GNU Lesser +# General Public License, version 3 or any later version (LGPLv3 or +# later), or the GNU General Public License, version 2 (GPLv2), in all +# cases as published by the Free Software Foundation. +# + +import socket +import time + +from eventsapiconf import SERVER_ADDRESS +from eventtypes import all_events + +from utils import logger, setup_logger + +# Run this when this lib loads +setup_logger() + + +def gf_event(event_type, **kwargs): + if not isinstance(event_type, int) or event_type >= len(all_events): + logger.error("Invalid Event Type: {0}".format(event_type)) + return + + try: + client = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) + client.connect(SERVER_ADDRESS) + except socket.error as e: + logger.error("Unable to connect to events.sock: {0}".format(e)) + return + + # Convert key value args into KEY1=VALUE1;KEY2=VALUE2;.. + msg = "" + for k, v in kwargs.items(): + msg += "{0}={1};".format(k, v) + + # + msg = "{0} {1} {2}".format(int(time.time()), event_type, msg.strip(";")) + + try: + client.sendall(msg) + except socket.error as e: + logger.error("Unable to Send message: {0}".format(e)) -- cgit