No examples for streaming about oci-python-sdk

[jodoglevy]

Thanks for reporting, we'll be working on this shortly.

[rosalexander]

Hey @luigisaetta,

I played with the streaming service a while ago. Maybe this could help you get started?

import os
import oci
import json
from base64 import b64decode, b64encode

def send_msg():

    stream_id = 'ENTER STREAM OCID HERE'
    config = oci.config.from_file()

    #Create stream client
    stream_client = oci.streaming.StreamClient(config)
    #Create Message Entry Details
    msg_entry = oci.streaming.models.PutMessagesDetailsEntry()
    msg_entry.value = b64encode(bytes('Hello word!', 'utf-8')).decode('utf-8')

    #Create Message Entry
    msgs = oci.streaming.models.PutMessagesDetails()
    msgs.messages = [msg_entry]

    #Put messages
    stream_client.put_messages(stream_id, msgs)


def get_msgs():
    #Create cursor to retrieve messages
    cursor_details = oci.streaming.models.CreateCursorDetails()
    cursor_details.partition = "0"
    cursor_details.type = "TRIM_HORIZON"
    cursor = stream_client.create_cursor(stream_id, cursor_details)
    r = stream_client.get_messages(stream_id, cursor.data.value)

    msgs = []
    if len(r.data):
        for msg in r.data:
            msgs.append(b64decode(msg.value).decode('utf-8'))
    
    return msgs

[jyotisaini]

Hi , we have added an example to show how to use Streaming service from the SDK. It is available here https://github.com/oracle/oci-python-sdk/blob/master/examples/stream_example.py
closing the issue.