python-anodot 2.0.7

Anodot API python package

Anodot API python package

Install:

pip install python-anodot

Posting metrics

More about the flow and protocols you can read here Posting metrics with Anodot API

Note:

• All dots and spaces in measurement names and in dimensions are replaced with an underscore _
• When you pass more than 1000 events to the anodot.send function they are splitted into chuncks before sending
• Events should be sorted by timestamp in the ascending order

Protocol 2.0

import anodot
import logging
import sys

from datetime import datetime

data = [
    {"time": "2020-01-01 00:00:00", "packets_in": 100, "packets_out": 120, "host": "host134", "region": "region1"},
    {"time": "2020-01-01 00:01:00", "packets_in": 163, "packets_out": 130, "host": "host126", "region": "region1"},
    {"time": "2020-01-01 00:02:00", "packets_in": 215, "packets_out": 140, "host": "host101", "region": "region2"}
]

VERSION = 1

events = []
for event in data:
    timestamp = datetime.strptime(event['time'], '%Y-%m-%d %H:%M:%S')
    events.append(
        anodot.Metric20(
            what='packets_in',
            value=event['packets_in'],
            target_type=anodot.TargetType.GAUGE,
            timestamp=timestamp,
            dimensions={'host': event['host'], 'region': event['region']},
            tags={'tag_name': ['tag_value']},
            version=VERSION,
        )
    )
    events.append(
        anodot.Metric20(
            what='packets_out',
            value=event['packets_out'],
            target_type=anodot.TargetType.GAUGE,
            timestamp=timestamp,
            dimensions={'host': event['host'], 'region': event['region']},
            tags={'tag_name': ['tag_value']},
            version=VERSION,
        )
    )

logger = logging.getLogger(__name__)
logger.setLevel(logging.INFO)
handler = logging.StreamHandler(sys.stdout)
handler.setFormatter(logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s'))
logger.addHandler(handler)

anodot.send(events, token='datacollectiontoken', logger=logger, base_url='https://app.anodot.com')

Protocol 3.0

import anodot
import logging
import sys

from datetime import datetime

data = [
    {"time": "2020-01-01 00:00:00", "packets_in": 100, "packets_out": 120, "host": "host134", "region": "region1"},
    {"time": "2020-01-01 00:01:00", "packets_in": 163, "packets_out": 130, "host": "host126", "region": "region1"},
    {"time": "2020-01-01 00:02:00", "packets_in": 215, "packets_out": 140, "host": "host101", "region": "region2"}
]

VERSION = 1

api_client = anodot.ApiClient('accesskeyhere', base_url='https://app.anodot.com')
schema = api_client.create_schema(
    anodot.Schema(
        name='new_schema',
        dimensions=['host', 'region'],
        measurements=[
            anodot.Measurement('packets_in', anodot.Aggregation.AVERAGE),
            anodot.Measurement('packets_out', anodot.Aggregation.AVERAGE),
        ],
        missing_dim_policy=anodot.MissingDimPolicy(action=anodot.MissingDimPolicyAction.FAIL),
        version=VERSION,
    )
)

events = []
for event in data:
    timestamp = datetime.strptime(event['time'], '%Y-%m-%d %H:%M:%S')
    events.append(
        anodot.Metric30(
            schema_id=schema['schema']['id'],
            measurements={"packets_in": event['packets_in'], "packets_out": event['packets_out']},
            timestamp=timestamp,
            dimensions={'host': event['host'], 'region': event['region']},
            tags={'tag_name': ['tag_value']},
        )
    )

logger = logging.getLogger(__name__)
logger.setLevel(logging.INFO)
handler = logging.StreamHandler(sys.stdout)
handler.setFormatter(logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s'))
logger.addHandler(handler)

anodot.send(
    events,
    token='datacollectiontoken',
    logger=logger,
    base_url='https://app.anodot.com',
    protocol=anodot.Protocol.ANODOT30,
)

anodot.send_watermark(
    anodot.Watermark(
        schema_id=schema['schema']['id'],
        timestamp=datetime.strptime('2020-01-01 00:03:00', '%Y-%m-%d %H:%M:%S'),
    ),
    token='datacollectiontoken',
    logger=logger,
    base_url='https://app.anodot.com',
)

Posting metrics (for package version <2.0)

Example

import logging
import sys

from anodot import metric
from datetime import datetime

data = [
    {"time": "2020-01-01 00:00:00", "packets_in": 100, "packets_out": 120, "host": "host134", "region": "region1"},
    {"time": "2020-01-01 00:01:00", "packets_in": 163, "packets_out": 130, "host": "host126", "region": "region1"},
    {"time": "2020-01-01 00:02:00", "packets_in": 215, "packets_out": 140, "host": "host101", "region": "region2"}
]

VERSION = 1

events = []
for event in data:
    timestamp = datetime.strptime(event['time'], '%Y-%m-%d %H:%M:%S')
    events.append(
        metric.Metric(
            what='packets_in',
            value=event['packets_in'],
            target_type=metric.TargetType.GAUGE,
            timestamp=timestamp,
            dimensions={'host': event['host'], 'region': event['region']},
            tags={'tag_name': ['tag_value']},
            version=VERSION
        )
    )
    events.append(
        metric.Metric(
            what='packets_out',
            value=event['packets_out'],
            target_type=metric.TargetType.GAUGE,
            timestamp=timestamp,
            dimensions={'host': event['host'], 'region': event['region']},
            tags={'tag_name': ['tag_value']},
            version=VERSION
        )
    )

logger = logging.getLogger(__name__)
logger.setLevel(logging.INFO)
handler = logging.StreamHandler(sys.stdout)
handler.setFormatter(logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s'))
logger.addHandler(handler)

metric.send(events, token='datacollectiontoken', logger=logger, base_url='https://app.anodot.com')