The panko.event.storage.impl_hbase Module

class panko.event.storage.impl_hbase.Connection(url)[source]

Bases: panko.storage.hbase.base.Connection, panko.event.storage.base.Connection

Put the event data into a HBase database

Collections:

  • events:

    • row_key: timestamp of event’s generation + uuid of event in format: “%s:%s” % (ts, Event.message_id)

    • Column Families:

      f: contains the following qualifiers:

      • event_type: description of event’s type

      • timestamp: time stamp of event generation

      • all traits for this event in format:

        "%s:%s" % (trait_name, trait_type)
        
clear()[source]
get_event_types()[source]

Return all event types as an iterable of strings.

get_events(event_filter, limit=None)[source]

Return an iter of models.Event objects.

Parameters:event_filter – storage.EventFilter object, consists of filters for events that are stored in database.
get_trait_types(event_type)[source]

Return a dictionary containing the name and data type of the trait.

Only trait types for the provided event_type are returned.

Parameters:event_type – the type of the Event
get_traits(event_type, trait_type=None)[source]

Return all trait instances associated with an event_type.

If trait_type is specified, only return instances of that trait type. :param event_type: the type of the Event to filter by :param trait_type: the name of the Trait to filter by

record_events(event_models)[source]

Write the events to Hbase.

Parameters:event_models – a list of models.Event objects.
upgrade()[source]

Previous topic

The panko.event.storage.impl_elasticsearch Module

Next topic

The panko.event.storage.impl_log Module

Project Source

This Page