REQUIREMENTS

pip install mlp_tracking

USAGE EXAMPLE

from mlp_tracking import MlpTracker, PipeType, IssueModule
import os


# initialize 
tracker = MlpTracker(
    pipe_type=PipeType.FAQ_PREDIC_PIPE.value,
    issue_module=IssueModule.ML.value,
    # you may get kafka_servers from environments
    kafka_servers=os.environ.get('KAFKA_SERVERS', ''),
    kafka_username=os.environ.get('KAFKA_USERNAME', ''),
    kafka_password=os.environ.get('KAFKA_PASSWORD', ''),
)


# send event
tracker.send(
    message='predict error',
    reason='model not found',
)