mlp-tracking 0.0.1

mlp_tracking

REQUIREMENTS

pip install ml_platform_client>=0.3.18.5
pip install confluent_kafka==1.7.0

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',
)