Creazione di un connettore con un'origine coda

Creare un connettore nell'hub connettore per trasferire i messaggi da una coda nel servizio Coda a un servizio di destinazione.

Per ulteriori informazioni sul servizio Coda, vedere Coda.

Un connettore definito con un'origine coda e un task funzione (facoltativo) supporta le destinazioni seguenti: Funzioni, Notifiche, Storage degli oggetti e Streaming.

Per un esempio del workflow Hub connettore, vedere Panoramica dell'hub connettore.

Per uno scenario che coinvolge una destinazione funzione, vedere Scenario: invio di messaggi coda a una funzione.

Prima di iniziare

Per selezionare una coda per un connettore, è necessario disporre dell'autorizzazione per leggere la coda. Vedere Policy IAM (Securing Connector Hub).

Polling lungo

Per impostazione predefinita, i connettori utilizzano il polling lungo per leggere i messaggi dalle code. Il polling lungo è utile per impedire nuovi tentativi di loop serrato quando la coda è vuota. Il timeout di lettura per la lettura da una coda è di 30 secondi. In ogni operazione di spostamento, il connettore attende che i messaggi consumabili siano disponibili nella coda. Se il timeout di lettura viene superato e non sono disponibili messaggi per l'utilizzo, il connettore termina la richiesta e prova con un'altra richiesta.

Filtri e messaggi consumati

È possibile filtrare una coda per canali specifici. Affinché i parametri API e CLI filtrino una coda, vedere Utilizzo dei messaggi da un canale. Un messaggio che è stato trasferito alla destinazione del connettore viene considerato "consumato". Per soddisfare i requisiti del servizio Coda, il connettore elimina i messaggi trasferiti dalla coda di origine. Per ulteriori informazioni, vedere Utilizzo dei messaggi.

Periodo di conservazione: origine coda

Il periodo di conservazione per l'origine coda nell'hub connettore dipende dalla configurazione della coda. Vedere Creazione di una coda. Per ulteriori informazioni sulla consegna, vedere Dettagli consegna.

1. Nella pagina elenco Connettori, selezionare Crea connettore. Se è necessaria assistenza per trovare la pagina dell'elenco, vedere Elenca connettori.
2. Nella pagina Crea connettore, immettere un nome riconoscibile dall'utente per il nuovo connettore e una descrizione facoltativa. Evitare di inserire informazioni riservate.
3. Selezionare il compartimento in cui memorizzare il nuovo connettore.
4. In Configura connettore, in Origine, selezionare Coda.
5. Per Destinazione, selezionare il servizio a cui si desidera trasferire i messaggi:
  
  Funzioni: inviare messaggi da una coda a una funzione.
  
  Notifiche: inviare messaggi da una coda a un argomento. Le notifiche sono supportate solo quando non è definito alcun task funzione.
  
  Storage degli oggetti: invia messaggi da una coda a un bucket.
  
  Streaming: consente di inviare messaggi da una coda a un flusso.
6. (Facoltativo) Per abilitare i log di servizio per il nuovo connettore, selezionare lo switch Log e fornire i valori riportati di seguito.
  
  Categoria log: il valore Tracciamento connettore viene selezionato automaticamente.
  
  Compartimento: selezionare il compartimento che si desidera memorizzare i log del servizio per il connettore.
  
  Gruppo di log: selezionare il gruppo di log desiderato per la memorizzazione dei log del servizio. Per creare un nuovo gruppo di log, selezionare Crea nuovo gruppo, quindi immettere un nome.
  
  Nome log: è possibile immettere un nome per il log.
  
  Mostra opzioni avanzate:
  
  Conservazione dei log: è possibile specificare per quanto tempo conservare i log del servizio (impostazione predefinita: 30 giorni).
7. In Configura connessione di origine, selezionare la coda contenente i messaggi desiderati:
  
  Compartimento: selezionare il compartimento contenente la coda desiderata.
  
  Coda: selezionare la coda che contiene i messaggi che si desidera.
  Nota
  
  Per selezionare una coda per un connettore, è necessario disporre dell'autorizzazione per leggere la coda. Vedere Policy IAM (Securing Connector Hub).
  
  Filtro canale (in Filtro messaggi) (facoltativo): per filtrare i messaggi dai canali nella coda, immettere un valore.
  
  Ad esempio, per filtrare i messaggi in base all'ID canale, immettere l'ID canale.
  
  Per i valori supportati, vedere channelFilter all'indirizzo GetMessages (API coda).
  
  Nota
  
  Un messaggio trasferito alla destinazione del connettore viene considerato "consumato". Per soddisfare i requisiti del servizio Coda, il connettore elimina i messaggi trasferiti dalla coda di origine. Per ulteriori informazioni, vedere Utilizzo dei messaggi.
8. (Facoltativo) In Configura task funzione, configurare un task funzione per elaborare i messaggi dalla coda utilizzando il servizio Funzioni:
  
  Seleziona task: selezionare Funzione.
  
  Compartimento: selezionare il compartimento contenente la funzione desiderata.
  
  Applicazione funzione: selezionare il nome dell'applicazione funzione che include la funzione desiderata.
  
  Funzione: selezionare il nome della funzione che si desidera utilizzare per elaborare i dati ricevuti dall'origine.
  Per essere utilizzata dal connettore come task, la funzione deve essere configurata in modo da restituire una delle seguenti risposte:
  
  Lista di voci JSON (deve impostare l'intestazione di risposta Content-Type=application/json)
  
  Voce JSON singola (deve impostare l'intestazione di risposta Content-Type=application/json)
  
  Oggetto binario singolo (deve impostare l'intestazione di risposta Content-Type=application/octet-stream)
  
  Mostra opzioni aggiuntive: selezionare questo collegamento e specificare i limiti per ogni batch di dati inviato alla funzione. Per utilizzare le impostazioni manuali, fornire i valori per il limite di dimensione batch (KB) e il limite di tempo batch (secondi).
  
  Considerazioni per le funzioni:
  
  L'hub connettore non analizza l'output del task funzione. L'output del task funzione viene scritto così com'è nella destinazione. Ad esempio, quando si utilizza una destinazione Notifiche con un task funzione, tutti i messaggi vengono inviati come BLOB JSON di tipo RAW.
  
  Le funzioni vengono richiamate in modo sincrono con 6 MB di dati per richiamo. Se i dati superano i 6 MB, il connettore richiama di nuovo la funzione per spostare i dati oltre il limite. Tali richiami vengono gestiti in sequenza.
  
  Le funzioni possono essere eseguite per un massimo di cinque minuti. Vedere Dettagli consegna.
  
  Le funzioni sono limitate alle funzioni scalari.
9. Se come destinazione è stata selezionata l'opzione Funzioni, in Configura destinazione configurare la funzione in cui inviare i messaggi dalla coda. Quindi, andare al passo 15.
  
  Compartimento: selezionare il compartimento contenente la funzione desiderata.
  
  Applicazione funzione: selezionare il nome dell'applicazione funzione che contiene la funzione desiderata.
  
  Funzione: selezionare il nome della funzione a cui si desidera inviare i dati.
  
  Mostra opzioni aggiuntive: selezionare questo collegamento e specificare i limiti per ogni batch di dati inviato alla funzione. Per utilizzare le impostazioni manuali, fornire i valori per il limite di dimensione batch (KB o numero di messaggi) e il limite di tempo batch (secondi).
  Ad esempio, limitare la dimensione del batch selezionando 5.000 kilobyte o 10 messaggi. Un limite di tempo batch di esempio è di 5 secondi.
  
  Considerazioni per le destinazioni delle funzioni:
  
  Il connettore svuota i dati di origine come lista JSON in batch. La dimensione massima del batch, o payload, è di 6 MB.
  
  Le funzioni vengono richiamate in modo sincrono con 6 MB di dati per richiamo. Se i dati superano i 6 MB, il connettore richiama di nuovo la funzione per spostare i dati oltre il limite. Tali richiami vengono gestiti in sequenza.
  
  Le funzioni possono essere eseguite per un massimo di cinque minuti. Vedere Dettagli consegna.
  
  Non restituire i dati dalle destinazioni Funzioni ai connettori. Connector Hub non legge i dati restituiti dalle destinazioni Functions.
10. Se come destinazione è stata selezionata l'opzione Notifiche, in Configura destinazione configurare l'argomento in cui inviare i messaggi dalla coda. Quindi, andare al passo 15.
  
  Compartimento: selezionare il compartimento contenente l'argomento desiderato.
  
  Argomento: selezionare il nome dell'argomento al quale si desidera inviare i dati.
  
  Formato messaggio: selezionare l'opzione desiderata.
  Nota
  
  Le opzioni Formato messaggio sono disponibili solo per i connettori con origine di log. Queste opzioni non sono disponibili per i connettori con task funzione. Quando le opzioni Formato messaggio non sono disponibili, i messaggi vengono inviati come BLOB JSON di tipo RAW.
  
  Invia messaggi formattati: layout semplificato e intuitivo.
  Per visualizzare i protocolli di sottoscrizione e i tipi di messaggio supportati per i messaggi formattati, vedere Formattazione descrittiva.
  
  Invia messaggi raw: blob JSON raw.
  
  Considerazioni per le destinazioni delle notifiche:
  
  La dimensione massima dei messaggi per la destinazione Notifiche è di 128 KB. Qualsiasi messaggio che supera la dimensione massima viene eliminato.
  
  I messaggi SMS mostrano risultati imprevisti per determinate configurazioni del connettore. Questo problema è limitato agli argomenti che contengono sottoscrizioni SMS per le configurazioni connettore indicate. Per ulteriori informazioni, vedere Più messaggi SMS per una singola notifica.
11. Se come destinazione è stato selezionato Storage degli oggetti, in Configura destinazione configurare il bucket a cui inviare i messaggi dalla coda. Quindi, andare al passo 15.
  
  Compartimento: selezionare il compartimento contenente il bucket desiderato.
  
  Bucket: selezionare il nome del bucket a cui si desidera inviare i dati.
  
  Prefisso nome oggetto: è possibile immettere un valore di prefisso.
  
  Mostra opzioni aggiuntive: selezionare questo collegamento e, facoltativamente, immettere i valori per la dimensione batch (in MB) e il tempo batch (in millisecondi).
  
  Considerazioni per le destinazioni dello storage degli oggetti:
  
  Dettagli rinnovo batch:
  
  Dimensione rollover batch: 100 MB
  
  Tempo di rollover batch: 7 minuti
  
  I file salvati nello storage degli oggetti vengono compressi utilizzando gzip.
  
  Formato dei dati spostati da un'origine di monitoraggio: oggetti. Le partizioni del connettore eseguono l'origine dei dati dal servizio di monitoraggio in base allo spazio di nomi delle metriche e scrivono i dati per ogni gruppo (spazio di nomi) in un oggetto. Ogni nome oggetto include i seguenti elementi.
  
  <object_name_prefix>/<service_connector_ocid>/<metric_compartment_ocid>/<metric_namespace>/<data_start_timestamp>_<data_end_timestamp>.<sequence_number>.<file_type>.gz
  
  All'interno di un oggetto, ogni set di datapoint viene aggiunto a una nuova riga.
12. Se come destinazione è stata selezionata l'opzione Streaming, in Configura destinazione configurare il flusso a cui inviare i messaggi dalla coda.
  
  Nota
  
  Per selezionare un pool di flussi e un flusso per un connettore, è necessario disporre dell'autorizzazione per leggere il pool di flussi e il flusso. Vedere Policy IAM (Securing Connector Hub). La configurazione dell'endpoint privato è supportata. Per utilizzare un endpoint privato, vedere Prerequisiti degli endpoint privati per Streams.
  
  Compartimento: selezionare il compartimento contenente il flusso desiderato.
  
  Via: selezionare il nome del flusso a cui si desidera inviare i dati.
  
  Considerazioni per le destinazioni di streaming:
  
  Formato di dati spostati da un'origine di monitoraggio: ogni oggetto viene scritto come messaggio separato.
13. Per accettare i criteri predefiniti, selezionare il collegamento Crea fornito per ogni criterio predefinito.
  
  I criteri predefiniti vengono offerti per consentire a questo connettore di accedere ai servizi di origine, task e destinazione.
  
  È possibile ottenere questa autorizzazione mediante questi criteri predefiniti o mediante criteri basati su gruppi. I criteri predefiniti vengono offerti ogni volta che si utilizza la console per creare o modificare un connettore. L'unica eccezione è quando il criterio esatto esiste già in IAM, nel qual caso il criterio predefinito non viene offerto. Per ulteriori informazioni su questo requisito di autorizzazione, vedere Autenticazione e autorizzazione.
  
  Se non si dispone delle autorizzazioni per accettare i criteri predefiniti, contattare l'amministratore.
  
  I criteri creati automaticamente rimangono quando vengono eliminati i connettori. Si consiglia di eliminare i criteri associati quando si elimina il connettore.
  
  Per rivedere un criterio appena creato, selezionare il collegamento vista associato.
14. (Facoltativo) Aggiungere una o più tag al connettore: selezionare Mostra opzioni avanzate per visualizzare la sezione Aggiungi tag.
  Se si dispone delle autorizzazioni per creare una risorsa, si dispone anche delle autorizzazioni per applicare le tag in formato libero a tale risorsa. Per applicare una tag defined, è necessario disporre delle autorizzazioni per utilizzare la tag namespace. Per ulteriori informazioni sull'applicazione di tag, vedere Tag risorsa. Se non si è certi di applicare le tag, saltare questa opzione o chiedere a un amministratore. È possibile applicare le tag in un secondo momento.
15. Selezionare Crea.
Il processo di creazione inizia e ne viene visualizzato l'avanzamento. Al termine, viene visualizzata la pagina dei dettagli del connettore.
Utilizzare il comando oci sch service-connector create e i parametri richiesti per creare un connettore con un'origine Coda.
oci sch service-connector create [...] --source <queue_json_input>
Per passare i dettagli di origine all'interfaccia CLI utilizzando un file JSON, effettuare le operazioni riportate di seguito.
```
oci sch service-connector create [...] --source file:queue_source.json
```
Contenuto file JSON di esempio:
```
{
    "kind": "plugin",
    "pluginName": "QueueSource",
    "configMap": {
        "queueId": "<queue_json_input>"
    }
}
```
Per un elenco completo dei parametri e dei valori per i comandi CLI, consultare il manuale CLI Command Reference.
Eseguire l'operazione CreateServiceConnector per creare un connettore.

Per creare un connettore con un'origine Coda, inserire in source nella richiesta (CreateServiceConnectorDetails) un plugin connettore che utilizza Queue (pluginName QueueSource, con ogni OCID coda in configMap). Per un esempio, vedere PluginSourceDetails.

Confermare che il nuovo connettore sposta i dati

Dopo aver creato il connettore, confermarne lo spostamento.

Abilita log per consentire al connettore di ottenere dettagli sul flusso di dati.
Controllare i risultati previsti nel servizio di destinazione.

La conferma dello spostamento dei dati consente di evitare la disattivazione automatica, che si verifica quando un connettore si guasta per un lungo periodo di tempo.