Documentation Oracle Cloud Infrastructure

Démarrage rapide du kit SDK pour Go avec Streaming

Publiez et utilisez des messages dans le service Streaming à l'aide du kit SDK OCI pour Go.

Ce démarrage rapide vous explique comment utiliser le kit SDK Oracle Cloud Infrastructure (OCI) pour Go et Oracle Cloud Infrastructure Streaming afin de publier et d'utiliser des messages.

Pour plus d'informations sur les concepts clés et Streaming, reportez-vous à Présentation de Streaming. Pour plus d'informations sur l'utilisation des kits SDK OCI, reportez-vous aux guides SDK.

Prérequis

  1. Afin d'utiliser le kit SDK pour Go, vous devez disposer des éléments suivants :

    • Un compte Oracle Cloud Infrastructure.
    • Un utilisateur créé dans ce compte, dans un groupe avec une stratégie qui octroie les droits d'accès requis. Cet utilisateur peut être vous-même, ou une autre personne/un autre système devant appeler l'API. Pour obtenir un exemple de configuration d'un nouvel utilisateur, d'un nouveau groupe, d'un nouveau compartiment et d'une nouvelle stratégie, reportez-vous à Ajout d'utilisateurs. Pour obtenir la liste des stratégies standard que vous pouvez utiliser, reportez-vous à Stratégies courantes.
    • Une paire de clés utilisée lors de la signature des demandes d'API, avec la clé publique téléchargée vers Oracle. Seul l'utilisateur appelant l'API doit disposer de la clé privée. Pour plus d'informations, reportez-vous à Fichier de configuration du kit SDK.
  2. Collectez l'adresse des messages et l'OCID d'un flux de données. Pour connaître les étapes d'obtention des détails d'un flux de données, reportez-vous à Obtention des détails d'un flux de données. Dans le cadre de ce démarrage rapide, le flux de données doit utiliser une adresse publique et laisser Oracle gérer le cryptage. Si vous n'avez pas de flux existant, reportez-vous à Création d'un flux de données et à Création d'un pool de flux de données.
  3. Effectuez une installation en local. Si nécessaire, suivez ces instructions. Assurez-vous que go figure dans PATH.

  4. Visual Studio Code (recommandé) ou tout autre environnement de développement intégré (IDE) ou éditeur de texte.

  5. Assurez-vous que vous disposez d'un fichier de configuration de kit SDK valide. Pour les environnements de production, vous devez utiliser l'autorisation de principal d'instance.

Production de messages

  1. Ouvrez votre éditeur favori, tel que Visual Studio Code, à partir du répertoire de travail vide wd.
  2. Créez un fichier nommé Producer.go dans ce répertoire.

  3. Ajoutez le code suivant au fichier Producer.go. Remplacez les valeurs des variables ociConfigFilePath, ociProfileName, ociStreamOcid et ociMessageEndpoint du fragment de code suivant par les valeurs applicables à votre location.

    package main

import (
	"context"
	"fmt"
	"strconv"

	"github.com/oracle/oci-go-sdk/v36/common"
	"github.com/oracle/oci-go-sdk/v36/example/helpers"
	"github.com/oracle/oci-go-sdk/v36/streaming"
)

const ociMessageEndpoint = "<stream_message_endpoint>"
const ociStreamOcid = "<stream_OCID>"
const ociConfigFilePath = "<config_file_path>"
const ociProfileName = "<config_file_profile_name>"

func main() {
	fmt.Println("Go oci oss sdk example producer")
	putMsgInStream(ociMessageEndpoint, ociStreamOcid)
}

func putMsgInStream(streamEndpoint string, streamOcid string) {
	fmt.Println("Stream endpoint for put msg api is: " + streamEndpoint)

	provider, err := common.ConfigurationProviderFromFileWithProfile(ociConfigFilePath, ociProfileName, "")
	helpers.FatalIfError(err)

	streamClient, err := streaming.NewStreamClientWithConfigurationProvider(provider, streamEndpoint)
	helpers.FatalIfError(err)

	// Create a request and dependent object(s).
	for i := 0; i < 5; i++ {
		putMsgReq := streaming.PutMessagesRequest{StreamId: common.String(streamOcid),
			PutMessagesDetails: streaming.PutMessagesDetails{
				// we are batching 2 messages for each Put Request
				Messages: []streaming.PutMessagesDetailsEntry{
					{Key: []byte("key dummy-0-" + strconv.Itoa(i)),
						Value: []byte("value dummy-" + strconv.Itoa(i))},
					{Key: []byte("key dummy-1-" + strconv.Itoa(i)),
						Value: []byte("value dummy-" + strconv.Itoa(i))}}},
		}

		// Send the request using the service client
		putMsgResp, err := streamClient.PutMessages(context.Background(), putMsgReq)
		helpers.FatalIfError(err)

		// Retrieve value from the response.
		fmt.Println(putMsgResp)
	}

}
  4. Enregistrez Producer.go.

  5. Ouvrez le terminal et utilisez la commande cd pour passer au répertoire wd. Exécutez les commandes suivantes, dans l'ordre :

    1. Cette commande crée le fichier go.mod dans le répertoire wd :

      go mod init oss_producer_example/v0

    2. Cette commande installe le kit SDK OCI pour Go et pour Streaming :

      go mod tidy

    3. Cette commande exécute l'exemple :

      go run Producer.go
  6. Afficher les derniers messages envoyés au flux de données : affichez les derniers messages envoyés au flux de données pour vérifier que la production a réussi.

Utilisation des messages

  1. Tout d'abord, assurez-vous que le flux de données dont vous souhaitez utiliser des messages en contient. Vous pouvez utiliser la console pour produire un message de test, ou vous servir du flux de données et des messages créés dans ce démarrage rapide.

  2. Ajoutez le code suivant au fichier Consumer.go. Remplacez les valeurs des variables ociConfigFilePath, ociProfileName, ociStreamOcid et ociMessageEndpoint du fragment de code suivant par les valeurs applicables à votre location.

    package main

import (
	"context"
	"fmt"

	"github.com/oracle/oci-go-sdk/v36/common"
	"github.com/oracle/oci-go-sdk/v36/example/helpers"
	"github.com/oracle/oci-go-sdk/v36/streaming"
)

const ociMessageEndpoint = "<stream_message_endpoint>"
const ociStreamOcid = "<stream_OCID>"
const ociConfigFilePath = "<config_file_path>"
const ociProfileName = "<config_file_profile_name>"

func main() {
	fmt.Println("Go oci oss sdk example for consumer")
	getMsgWithGroupCursor(ociMessageEndpoint, ociStreamOcid)
}

func getMsgWithGroupCursor(streamEndpoint string, streamOcid string) {
	client, err := streaming.NewStreamClientWithConfigurationProvider(common.DefaultConfigProvider(), streamEndpoint)
	helpers.FatalIfError(err)

	grpCursorCreateReq0 := streaming.CreateGroupCursorRequest{
		StreamId: common.String(streamOcid),
		CreateGroupCursorDetails: streaming.CreateGroupCursorDetails{Type: streaming.CreateGroupCursorDetailsTypeTrimHorizon,
			CommitOnGet:  common.Bool(true),
			GroupName:    common.String("Go-groupname-0"),
			InstanceName: common.String("Go-groupname-0-instancename-0"),
			TimeoutInMs:  common.Int(1000),
		}}

	// Send the request using the service client
	grpCursorResp0, err := client.CreateGroupCursor(context.Background(), grpCursorCreateReq0)
	helpers.FatalIfError(err)
	// Retrieve value from the response.
	fmt.Println(grpCursorResp0)

	simpleGetMsgLoop(client, streamOcid, *grpCursorResp0.Value)
}

func simpleGetMsgLoop(streamClient streaming.StreamClient, streamOcid string, cursorValue string) {

	for i := 0; i < 5; i++ {
		getMsgReq := streaming.GetMessagesRequest{Limit: common.Int(3),
			StreamId: common.String(streamOcid),
			Cursor:   common.String(cursorValue)}

		// Send the request using the service client
		getMsgResp, err := streamClient.GetMessages(context.Background(), getMsgReq)
		helpers.FatalIfError(err)

		// Retrieve value from the response.
		if len(getMsgResp.Items) > 0 {
			fmt.Println("Key : " + string(getMsgResp.Items[0].Key) + ", value : " + string(getMsgResp.Items[0].Value) + ", Partition " + *getMsgResp.Items[0].Partition)
		}
		if len(getMsgResp.Items) > 1 {
			fmt.Println("Key : " + string(getMsgResp.Items[1].Key) + ", value : " + string(getMsgResp.Items[1].Value) + ", Partition " + *getMsgResp.Items[1].Partition)
		}
		cursorValue = *getMsgResp.OpcNextCursor

	}
}
  3. Enregistrez Consumer.go.

  4. Ouvrez le terminal et utilisez la commande cd pour passer au répertoire wd. Exécutez les commandes suivantes, dans l'ordre :

    1. Cette commande crée le fichier go.mod dans le répertoire wd :

      go mod init oss_consumer_example/v0

    2. Cette commande installe le kit SDK OCI pour Go et pour Streaming :

      go mod tidy

    3. Cette commande exécute l'exemple :

      go run Consumer.go

  5. Des messages semblables à celui qui suit s'affichent :

    Go oci oss sdk example for consumer
{ RawResponse={200 OK 200 HTTP/1.1 1 1 map[Access-Control-Allow-Credentials:[true] ... }
Key : , value : Example Test Message 0, Partition 0
Key : , value : Example Test Message 0, Partition 0
Key : , value : Example Test Message 0, Partition 0
Key : , value : Example Test Message 0, Partition 0
Key : , value : Example Test Message 0, Partition 0
    Remarque

    Si vous avez utilisé la console pour produire un message de test, la clé de chaque message est Null.