davidohana

import csv
import json
import logging
import os

import requests

logger = logging.getLogger(__name__)

"""CSV format for users file:

davidohana

role_doc = {"role": "Admin"}
grafana_server_url = "https://localhost:3000"
patch_user_endpoint = grafana_server_url + "/api/org/users/"
role_end_point = patch_user_endpoint + str(user_id)
r = requests.patch(role_end_point,
                   json=role_doc,
                   verify=False,
                   auth=('admin', grafana_admin_password))

davidohana

permission_doc = {"isGrafanaAdmin": True}
grafana_server_url = "https://localhost:3000"
permission_end_point = "{}/api/admin/users/{}/permissions".format(grafana_server_url, user_id)
response = requests.put(permission_end_point,
                        json=permission_doc,
                        verify=False,
                        auth=('admin', grafana_admin_password))

davidohana

    grafana_server_url = "https://localhost:3000"
    add_user_endpoint = grafana_server_url + "/api/admin/users/"

    user_dict = {
        "name": "David Ohana",
        "email": "NotMyRealEmail@ibm.com",
        "login": "NotMyRealEmail@ibm.com",
        "password": "dummypass",
    }
    response = requests.post(

davidohana

alerts = alerts_client.get_alerts_list(
          service=service_filter,
          priority=min_priority_level,
          page=1,
          pageSize=batch_size_limit)

davidohana

service_filter = "service1"
priority=3
batch_size_limit=1000

def get_alert_list():
    return alerts_client.get_alerts_list(
        service=service_filter,
        priority=min_priority_level,
        page=1,
        pageSize=batch_size_limit

davidohana

def retry(func, ex_type=Exception, limit=0, wait_ms=100, wait_increase_ratio=2, logger=None):
    """
    Retry a function invocation until no exception occurs
    :param func: function to invoke
    :param ex_type: retry only if exception is subclass of this type
    :param limit: maximum number of invocation attempts
    :param wait_ms: initial wait time after each attempt in milliseconds.
    :param wait_increase_ratio: increase wait period by multiplying this value after each attempt.
    :param logger: if not None, retry attempts will be logged to this logging.logger
    :return: result of first successful invocation

davidohana

import logging
import socket
import sys

from colargulog import ColorizedArgsFormatter
from colargulog import BraceFormatStyleFormatter


def init_logging():
    root_logger = logging.getLogger()

davidohana

import logging
import logging.handlers
import re


class ColorCodes:
    grey = "\x1b[38;21m"
    green = "\x1b[1;32m"
    yellow = "\x1b[33;21m"
    red = "\x1b[31;21m"

davidohana

import logging
from colargulog import ColorizedArgsFormatter

root_logger = logging.getLogger()
console_handler = logging.StreamHandler(stream=sys.stdout)
console_format = "%(asctime)s - %(levelname)-8s - %(name)-25s - %(message)s"
colored_formatter = ColorizedArgsFormatter(console_format)
console_handler.setFormatter(colored_formatter)
root_logger.addHandler(console_handler)