Grafana notification to Yammer gateway

_README.md

Notification gateway from Grafana to Yammer

Why this GIST ?

Yammer notifications are not implemented in Grafana, by default. So I decided to develop a little gateway that publish Grafana alarm webhooks to Yammer thread.

Configuration

Grafana

Add Webhook notification channel to Grafana configuration pointing to gateway url (with following format). Check include image.

Yammer application

In your Yammer configuration panel, add a new custom app. Then generate development token. Copy/past it in env.txt.

Gateway url format

http://<grafana-yammer-gw>:<port>/publish/<yammer-group-id>

Build

docker build -t ziouf/grafana-yammer-gw -f dockerfile -q --rm .
docker run -d --env-file env.txt -p 80:80 ziouf/grafana-yammer-gw

dockerfile

FROM python:3-slim-stretch

ENV PORT 80
ENV IP 0.0.0.0
ENV WORKERS 1
ENV LOG_LEVEL info

COPY requirements.txt /tmp/
RUN pip install -r /tmp/requirements.txt && rm /tmp/requirements.txt

WORKDIR /opt
COPY gateway.py /opt/

CMD gunicorn -w ${WORKERS} -b ${IP}:${PORT} --log-level ${LOG_LEVEL} gateway:app

env.txt

TOKEN=...
PORT=80
WORKERS=2
LOG_LEVEL=info

gateway.py

import logging
import os
import sys
import yampy
from flask import Flask, request

TOKEN = os.environ.get('TOKEN')

app = Flask(__name__)
yam = yampy.Yammer(access_token=TOKEN)

if __name__ != '__main__':
    # Workarround to register Flask logger in Gunicorn logger
    gunicorn_logger = logging.getLogger('gunicorn.error')
    app.logger.handlers = gunicorn_logger.handlers
    app.logger.setLevel(gunicorn_logger.level)

    # If TOKEN not set, exit with error
    if TOKEN == None:
        msg = "Environment variable TOKEN must be set !"
        app.logger.error(msg)
        sys.exit(msg)
    

@app.route('/publish/<int:group_id>', methods=['POST'])
def publish(group_id):
    json_hook_data = request.get_json(force=True, silent=True)
    app.logger.debug("Received POST call for gid [{}] with data : {}".format(group_id, json_hook_data))

    # Prepare msg to publish
    msg = "{}: {} \n[{}: {}]".format(json_hook_data['title'], json_hook_data['message'], json_hook_data['ruleName'],
                                     json_hook_data['ruleUrl'])
    for m in json_hook_data['evalMatches']:
        msg = "{}\n => {} : {}".format(msg, m['metric'], m['value'])

    # Publish message on Yammer
    yam.messages.create(msg, group_id=group_id,
                        open_graph_object={'image': json_hook_data['imageUrl'], 'url': json_hook_data['imageUrl']},
                        topics=["Grafana", "Alarm", json_hook_data['ruleName']])

    return "Success"

requiements.txt

yampy3
flask
gunicorn