EXAMPLE: Query Datadog Event stream for time, expand items found in stream

events_children.py

import datetime
import pprint

from dogapi import dog_http_api as api

api.api_key = 'somesecret'
api.application_key = 'yetanothersecret'

start_time = 1375940459
end_time   = 1375980459

title_text = "reactionner"

def query_stream_for_timeframe(start, end):
    """get all events for timeframe"""
    return api.stream(start, end)

def find_my_event(events, title_text):
    """find a specifc event in the response"""
    for event in events:
        if title_text in str(event['title']):
            return event

def expand_aggregated_event_and_find_in_time(event, start, end):
    """This takes an aggregated event, and finds the children that
    fall in the time range"""
    found_children = []
    for child in event['children']:
        if child['date_happened'] in range(start, end):
            found_children.append(child)
    return found_children

events = query_stream_for_timeframe(start_time, end_time)

text_matching_event = find_my_event(events, title_text)

if text_matching_event['is_aggregate']:
    children = expand_aggregated_event_and_find_in_time(text_matching_event, start_time, end_time)

# pprint.pprint(children)

for child in children:
    ret = api.get_event(child['id'])
    print ret['title'], datetime.datetime.fromtimestamp(ret['date_happened']).strftime('%Y-%m-%d %H:%M:%S')