Elenca i cluster di connessione

L'elenco dei cluster di connessione consente di visualizzare i dettagli di tutti i cluster di connessione in un unico riquadro, inclusi dettagli quali l'integrità dei cluster, le località, l'uptime dei cluster, le dimensioni di calcolo, il cluster Google Cloud Managed Service per Apache Kafka associato e le etichette.

Per elencare i cluster Connect, puoi utilizzare la console Google Cloud , gcloud CLI, la libreria client o l'API Managed Kafka. Non puoi utilizzare l'API Apache Kafka open source per elencare i cluster Connect.

Ruoli e autorizzazioni richiesti per elencare i cluster di connessione

Per ottenere le autorizzazioni necessarie per elencare i cluster Connect, chiedi all'amministratore di concederti il ruolo IAM Visualizzatore Kafka gestito (roles/managedkafka.viewer) nel progetto. Per saperne di più sulla concessione dei ruoli, consulta Gestisci l'accesso a progetti, cartelle e organizzazioni.

Questo ruolo predefinito contiene le autorizzazioni necessarie per elencare i cluster Connect. Per vedere quali sono esattamente le autorizzazioni richieste, espandi la sezione Autorizzazioni obbligatorie:

Autorizzazioni obbligatorie

Per elencare i cluster Connect sono necessarie le seguenti autorizzazioni:

Concedi l'autorizzazione per elencare i cluster nella posizione specificata: managedkafka.connectClusters.list
Concedi l'autorizzazione per visualizzare i dettagli del cluster nella posizione specificata: managedkafka.connectClusters.get

Potresti anche ottenere queste autorizzazioni con ruoli personalizzati o altri ruoli predefiniti.

Per saperne di più sul ruolo Visualizzatore Kafka gestito, consulta Ruoli predefiniti di Managed Service per Apache Kafka.

Visualizzare i cluster di connessione

Console

Nella console Google Cloud , vai alla pagina Connetti cluster.

Vai a Connetti cluster
Viene visualizzato l'elenco dei cluster che hai creato in un progetto. La pagina consente di visualizzare le seguenti proprietà del cluster:
- Nome: l'identificatore univoco del cluster Connect. Puoi utilizzarlo per fare riferimento al cluster Connect in varie operazioni.
- Stato: indica lo stato operativo attuale del cluster Connect, ad esempio Attivo.
- Posizione: la posizione geografica in cui è ospitato il cluster di connessione.
- Ora di aggiornamento: l'ora dell'ultimo aggiornamento del cluster di connessione.
- vCPUs: il numero di vCPU assegnate al cluster di connessione.
- Memoria: la quantità totale di memoria allocata al cluster Connect.
- Cluster Kafka principale: il cluster Managed Service per Apache Kafka associato al cluster di connessione.
- Etichette: coppie chiave-valore che puoi collegare al cluster Connect per scopi di organizzazione, filtraggio e automazione.

gcloud

In the Google Cloud console, activate Cloud Shell.

Activate Cloud Shell

At the bottom of the Google Cloud console, a Cloud Shell session starts and displays a command-line prompt. Cloud Shell is a shell environment with the Google Cloud CLI already installed and with values already set for your current project. It can take a few seconds for the session to initialize.
Utilizza il comando gcloud managed-kafka connect-clusters list per elencare i cluster di connessione:
```
gcloud managed-kafka connect-clusters list \
    --location=LOCATION
```
Per perfezionare ulteriormente l'elenco dei cluster di connessione, puoi utilizzare flag aggiuntivi:
```
gcloud managed-kafka connect-clusters list \
    --location=LOCATION \
    [--filter=EXPRESSION] \
    [--limit=LIMIT] \
    [--page-size=PAGE_SIZE] \
    [--sort-by=SORT_BY]
```
Sostituisci quanto segue:
- LOCATION: obbligatorio. La posizione dei cluster Connect che vuoi elencare.
- EXPRESSION: (facoltativo) un'espressione di filtro booleano da applicare all'elenco. Se l'espressione restituisce True, l'elemento viene incluso nell'elenco. Per maggiori dettagli ed esempi, esegui gcloud topic filters.
- LIMIT: (facoltativo) il numero massimo di cluster Connect da visualizzare. Se non specificato, vengono elencati tutti i cluster Connect.
- PAGE_SIZE: (facoltativo) il numero di risultati da mostrare per pagina. Se non viene specificata, il servizio determina una dimensione di pagina adatta.
- SORT_BY: (facoltativo) un elenco separato da virgole di campi in base a cui eseguire l'ordinamento. L'ordine di ordinamento predefinito è crescente. Per ordinare in ordine decrescente, anteponi ~ al campo.

Output di esempio:

NAME                   VCPU  MEMORY_BYTES  STATE   NETWORK
connect-cluster-alpha  3     3221225472    ACTIVE
connect-cluster-beta   3     3221225472    ACTIVE

Go

Prima di provare questo esempio, segui le istruzioni di configurazione di Go in Installare le librerie client. Per saperne di più, consulta la documentazione di riferimento dell'API Go di Managed Service per Apache Kafka.

Per eseguire l'autenticazione in Managed Service per Apache Kafka, configura le Credenziali predefinite dell'applicazione(ADC). Per saperne di più, vedi Configura ADC per un ambiente di sviluppo locale.

import (
	"context"
	"fmt"
	"io"

	"cloud.google.com/go/managedkafka/apiv1/managedkafkapb"
	"google.golang.org/api/iterator"
	"google.golang.org/api/option"

	managedkafka "cloud.google.com/go/managedkafka/apiv1"
)

func listConnectClusters(w io.Writer, projectID, region string, opts ...option.ClientOption) error {
	// projectID := "my-project-id"
	// region := "us-central1"
	ctx := context.Background()
	client, err := managedkafka.NewManagedKafkaConnectClient(ctx, opts...)
	if err != nil {
		return fmt.Errorf("managedkafka.NewManagedKafkaConnectClient got err: %w", err)
	}
	defer client.Close()

	locationPath := fmt.Sprintf("projects/%s/locations/%s", projectID, region)
	req := &managedkafkapb.ListConnectClustersRequest{
		Parent: locationPath,
	}
	clusterIter := client.ListConnectClusters(ctx, req)
	for {
		res, err := clusterIter.Next()
		if err == iterator.Done {
			break
		}
		if err != nil {
			return fmt.Errorf("clusterIter.Next() got err: %w", err)
		}
		fmt.Fprintf(w, "Got connect cluster: %v", res)
	}
	return nil
}

Java

Prima di provare questo esempio, segui le istruzioni di configurazione di Java in Installare le librerie client. Per saperne di più, consulta la documentazione di riferimento dell'API Java di Managed Service per Apache Kafka.

Per eseguire l'autenticazione in Managed Service per Apache Kafka, configura le Credenziali predefinite dell'applicazione. Per saperne di più, vedi Configura ADC per un ambiente di sviluppo locale.

import com.google.api.gax.rpc.ApiException;
import com.google.cloud.managedkafka.v1.ConnectCluster;
import com.google.cloud.managedkafka.v1.LocationName;
import com.google.cloud.managedkafka.v1.ManagedKafkaConnectClient;
import java.io.IOException;

public class ListConnectClusters {

  public static void main(String[] args) throws Exception {
    // TODO(developer): Replace these variables before running the example.
    String projectId = "my-project-id";
    String region = "my-region"; // e.g. us-east1
    listConnectClusters(projectId, region);
  }

  public static void listConnectClusters(String projectId, String region) throws Exception {
    try (ManagedKafkaConnectClient managedKafkaConnectClient = 
        ManagedKafkaConnectClient.create()) {
      LocationName locationName = LocationName.of(projectId, region);
      // This operation is being handled synchronously.
      for (ConnectCluster connectCluster : managedKafkaConnectClient
          .listConnectClusters(locationName).iterateAll()) {
        System.out.println(connectCluster.getAllFields());
      }
    } catch (IOException | ApiException e) {
      System.err.printf("managedKafkaConnectClient.listConnectClusters got err: %s\n", 
          e.getMessage());
    }
  }
}

Python

Prima di provare questo esempio, segui le istruzioni di configurazione di Python in Installare le librerie client. Per saperne di più, consulta la documentazione di riferimento dell'API Python di Managed Service per Apache Kafka.