onapsdk.dmaap package

Submodules

onapsdk.dmaap.dmaap module

Base Dmaap event store.

class onapsdk.dmaap.dmaap.Dmaap

Bases: onapsdk.dmaap.dmaap_service.DmaapService

Dmaap library provides functions for getting events from Dmaap.

dmaap_url = 'http://dmaap.api.simpledemo.onap.org:3904'
classmethod get_all_events(basic_auth)

Get all events stored in Dmaap.

Parameters

basic_auth (Dict[str, str]) – (Dict[str, str]) for example:{ ‘username’: ‘bob’, ‘password’: ‘secret’ }

Return type

dict

Returns

(dict) Events from Dmaap

get_all_events_url = 'http://dmaap.api.simpledemo.onap.org:3904/events'
classmethod get_all_topics(basic_auth)

Get all topics stored in Dmaap.

Parameters

basic_auth (Dict[str, str]) – (Dict[str, str]) for example:{ ‘username’: ‘bob’, ‘password’: ‘secret’ }

Return type

dict

Returns

(dict) Topics from Dmaap

get_all_topics_url = 'http://dmaap.api.simpledemo.onap.org:3904/topics'
classmethod get_events_for_topic(topic, basic_auth)

Get all events stored specific topic in Dmaap.

Parameters
  • topic (str) – (str) topic of events stored in Dmaap

  • basic_auth (Dict[str, str]) – (Dict[str, str]) for example:{ ‘username’: ‘bob’, ‘password’: ‘secret’ }

Return type

dict

Returns

(dict) Events from Dmaap

get_events_from_topic_url = '{}/events/{}/CG1/C1'

onapsdk.dmaap.dmaap_service module

Base VES module.

class onapsdk.dmaap.dmaap_service.DmaapService

Bases: onapsdk.onap_service.OnapService

Base DMAAP class.

Stores url to DMAAP API (edit if you want to use other).

Module contents

ONAP SDK Dmaap package.