Consommation de messages

À l'aide d'un curseur spécifié, consommez les messages d'un flux du service de flux.

Pour consommer des messages à partir d'un flux, vous devez :

  • Créer un curseur.
  • Utiliser le curseur pour obtenir ou lire des messages.
  • Utiliser le curseur retourné pour continuer la lecture des messages.

Vous pouvez utiliser un consommateur individuel pour lire des messages à partir d'un ou de plusieurs flux, ou utiliser des groupes de consommateurs pour lire des messages à partir d'un flux.

Voici les tâches que vous pouvez effectuer en rapport avec la consommation des messages.

Conseil

Vous pouvez également utiliser Oracle Cloud Infrastructure Connector Hub pour consommer des données à partir d'un flux et transmettre des messages au service Stockage d'objets ou à toute autre cible de centre de connecteurs prise en charge.

Vous pouvez afficher les derniers messages d'un flux à l'aide de la console. Toutefois, pour consommer des messages à partir du flux, vous utilisez l'interface de ligne de commande, l'API ou une trousse SDK pour créer et utiliser des curseurs.

Pour consommer des messages à l'aide de trousses SDK pour OCI, voir le guide du développeur pour le service de flux. Voir aussi Développement avec Kafka et le service de flux.

Politique GIA requise

Pour utiliser Oracle Cloud Infrastructure, un administrateur doit être membre d'un groupe auquel l'accès de sécurité est accordé dans une politique par un administrateur de location. Cet accès est requis que vous utilisiez la console ou l'API REST avec une trousse SDK, l'interface de ligne de commande ou un autre outil. Si vous obtenez un message indiquant que vous ne disposez pas de l'autorisation requise, vérifiez auprès de l'administrateur de la location quel type d'accès vous avez et dans quel compartiment votre accès fonctionne.

Pour les administrateurs : La politique sous Permettre aux administrateurs de gérer les ressources de diffusion en continu permet au groupe indiqué de tout faire avec la diffusion en continu et les ressources connexes du service de diffusion en continu.

Vous pouvez créer une politique qui donne à un locataire un accès au extraction en continu pour consommer des données à partir d'un flux d'un autre locataire. Pour plus d'informations sur les politiques de diffusion en continu, voir Accès aux ressources de diffusion en continu entre des locations et Informations détaillées sur le service de diffusion en continu.

Pour en savoir plus sur les politiques, voir Aperçu des politiques IAM.