Example Python Code for Posting a Message

requirements.txt:

git+ssh://git@github.com/StrongMind/pipeline-publisher-python.git

send_message.py:

import pipeline_publisher_python
from pipeline_publisher_python.rest import ApiException

api_instance = pipeline_publisher_python.MessagesApi()
api_instance.api_client.configuration.host = 'https://stage-di-data-pipeline-api.strongmind.com'
api_instance.api_client.configuration.username = 'enter_value_here'
api_instance.api_client.configuration.password = 'enter_value_here'

message = pipeline_publisher_python.Message(noun='test_message',
                                            meta={
                                                'foo': "bar"
                                            },
                                            identifiers={
                                                'id': 1
                                            },
                                            data={
                                                'example_key': 'example_value'
                                            })

try:
    # Creates a message on the pipeline
    api_instance.messages_post(message=message)
except ApiException as e:
    print("Exception when calling MessagesApi->messages_post: %s\n" % e)

Running it:

pip install -r requirements.txt
python send_message.py