Ori.livneh has uploaded a new change for review.
https://gerrit.wikimedia.org/r/81164
Change subject: Add 'statsd' EventLogging writer
......................................................................
Add 'statsd' EventLogging writer
This patch adds an EventLogging writer for statsd:// URIs. It will increment a
SCID-specific counter for each event that it reads.
Change-Id: I068bd64c5650e531734b2288c4be6b9f65e13e3e
---
M server/eventlogging/handlers.py
1 file changed, 11 insertions(+), 0 deletions(-)
git pull ssh://gerrit.wikimedia.org:29418/mediawiki/extensions/EventLogging
refs/changes/64/81164/1
diff --git a/server/eventlogging/handlers.py b/server/eventlogging/handlers.py
index b6a0d2f..3f8c912 100644
--- a/server/eventlogging/handlers.py
+++ b/server/eventlogging/handlers.py
@@ -17,6 +17,7 @@
import logging
import logging.handlers
import os
+import socket
import sys
import pymongo
@@ -93,6 +94,16 @@
pub.send_unicode(json_event + '\n')
+@writes('statsd')
+def statsd_writer(hostname, port, prefix='eventlogging'):
+ """Increments StatsD SCID counters for each event."""
+ addr = socket.gethostbyname(hostname), port
+ sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+ while 1:
+ stat = prefix + '.%(schema)s_%(revision)s:1' % (yield)
+ sock.sendto(stat.encode('utf-8'), addr)
+
+
@writes('stdout')
def stdout_writer(uri):
"""Writes events to stdout. Pretty-prints if stdout is a terminal."""
--
To view, visit https://gerrit.wikimedia.org/r/81164
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I068bd64c5650e531734b2288c4be6b9f65e13e3e
Gerrit-PatchSet: 1
Gerrit-Project: mediawiki/extensions/EventLogging
Gerrit-Branch: master
Gerrit-Owner: Ori.livneh <[email protected]>
_______________________________________________
MediaWiki-commits mailing list
[email protected]
https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
