Creación de un flujo
Configure y cree un flujo en el servicio Streaming.
Antes de publicar mensajes en un flujo o de consumir mensajes de un flujo, primero debe crear un flujo. Al crear un flujo, tenga en cuenta las estrategias de partición y seguridad. Para revisar los requisitos para crear y gestionar flujos, consulte Introducción a Streaming.
Para obtener información sobre el uso de la CLI, consulte Interfaz de línea de comandos (CLI). Para obtener una lista completa de los indicadores y las opciones disponibles para los comandos de la CLI, consulte la Referencia de la línea de comandos.
Nota
Los ejemplos de esta sección utilizan la sintaxis completa para todos los parámetros, por ejemplo--compartment-id
. Para algunos parámetros, hay versiones abreviadas que puede utilizar en su lugar, como-c
. Consulte la ayuda en pantalla de la CLI para conocer las instancias de un parámetro abreviado asociado con un comando.Puede crear un flujo en un compartimento o un pool de flujos. Los parámetros
--compartment-id
y--stream-pool-id
no se pueden especificar al mismo tiempo.oci streaming admin stream create --name <stream_name> --partitions <number_of_partitions> --compartment-id <compartment_OCID>
oci streaming admin stream create --name <stream_name> --partitions <number_of_partitions> --stream-pool-id <stream_pool_OCID>
Por ejemplo:
oci streaming admin stream create --name MyStream --partitions 5 --compartment-id ocid1.tenancy.oc1..exampleuniqueID { "data": { "compartment-id": "ocid1.tenancy.oc1..exampleuniqueID", "defined-tags": {}, "freeform-tags": {}, "id": "ocid1.stream.oc1.phx.exampleuniqueID", "lifecycle-state": "CREATING", "lifecycle-state-details": null, "messages-endpoint": "https://cell-1.streaming.us-phoenix-1.oci.oraclecloud.com", "name": "MyStream", "partitions": 5, "retention-in-hours": 24, "stream-pool-id": "ocid1.streampool.oc1.phx.exampleuniqueID", "time-created": "2020-11-02T19:12:22.385000+00:00" }, "etag": "\"d72d8103-f1ae-442a-822d-10f86cd097c5-25e61a9b-cc08-4fad-9908-40c9636d31d8\"" }
Utilice la operación de API CreateStream para crear flujos.
Para obtener más información sobre el uso de la API y la firma de solicitudes, consulte la documentación de la API de REST y Credenciales de seguridad. Para obtener información sobre los SDK, consulte Los SDK y la CLI.
Uso de los SDK de OCI
Para crear un flujo, utilice el método createStream
de StreamAdminClient
.
Consulte la Guía para desarrolladores de Streaming para obtener ejemplos detallados de SDK.
Uso de Resource Manager y Terraform
Utilice el recurso oci_streaming_stream
en configuraciones de Terraform para crear un flujo en un compartimento.
Por ejemplo:
resource "oci_streaming_stream" "stream" {
compartment_id = var.compartment_ocid
name = "<stream_name>"
partitions = "<number_of_partitions>"
retention_in_hours = "<retention_in_hours>"
}
Resource Manager es un servicio de Oracle Cloud Infrastructure (OCI) que le permite automatizar el proceso de aprovisionamiento de los recursos de OCI. Con el uso de Terraform, el gestor de recursos le ayuda a instalar, configurar y gestionar recursos con el modelo "infraestructura como código".
Una configuración de Terraform codifica la infraestructura en archivos de configuración declarativos. La configuración define los recursos que desea aprovisionar, las variables y las instrucciones específicas para aprovisionar los recursos
Puede utilizar Resource Manager o la CLI de Terraform con el proveedor de Terraform de OCI para ver cómo se representan los flujos y los pools de flujos en los archivos de configuración de Terraform.
Para obtener más información sobre la escritura de configuraciones para su uso con Resource Manager, consulte Configuraciones de Terraform para el gestor de recursos y Configuración de Terraform.