Google utilizza la tecnologia AI per tradurre i contenuti nella tua lingua preferita. Le traduzioni generate dall'AI potrebbero contenere errori.

Elenca i cluster di connessione

Managed Service per Apache Kafka ti consente di visualizzare lo stato di attività, l'allocazione delle risorse e i dettagli di configurazione di tutti i tuoi cluster Connect. Questa visualizzazione consolidata ti aiuta a gestire i cluster Connect in un unico posto.

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 Managed Kafka Viewer (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 località specificata: managedkafka.connectClusters.list
Concedi l'autorizzazione per ottenere i dettagli del cluster nella località specificata: managedkafka.connectClusters.get

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

Visualizza i cluster di connessione

Console

Nella console Google Cloud , vai alla pagina Connetti i cluster.

Vai a Cluster connessi
Vengono elencati i 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 di attività attuale del cluster Connect, ad esempio Attivo.
- Località: la posizione geografica in cui è ospitato il cluster Connect.
- Ora di aggiornamento: l'ora dell'ultimo aggiornamento del cluster connesso.
- vCPUs: il numero di vCPU assegnate al cluster Connect.
- Memoria: la quantità totale di memoria allocata al cluster Connect.
- Cluster Kafka principale: il cluster Managed Service per Apache Kafka associato al cluster Connect.
- Etichette: coppie chiave-valore che puoi collegare al cluster Connect per scopi di organizzazione, filtro e automazione.

gcloud

Nella console Google Cloud , attiva Cloud Shell.

Attiva Cloud Shell

Nella parte inferiore della console Google Cloud , viene avviata una sessione di Cloud Shell e viene visualizzato un prompt della riga di comando. Cloud Shell è un ambiente shell con Google Cloud CLI già installata e con valori già impostati per il progetto corrente. L'inizializzazione della sessione può richiedere alcuni secondi.
Utilizza il comando gcloud managed-kafka connect-clusters list per elencare i cluster di Connect:
```
gcloud managed-kafka connect-clusters list \
    --location=LOCATION
```
Per perfezionare ulteriormente l'elenco dei cluster di Connect, 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 località 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 ulteriori 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 visualizzare per pagina. Se non viene specificata, il servizio determina una dimensione di pagina appropriata.
- SORT_BY: (facoltativo) un elenco separato da virgole dei campi in base ai quali eseguire l'ordinamento. L'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

Vai

Prima di provare questo esempio, segui le istruzioni di configurazione di Go in Installa 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ù, consulta 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 riportate in Installa 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ù, consulta 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 Installa le librerie client. Per saperne di più, consulta la documentazione di riferimento dell'API Python di Managed Service per Apache Kafka.

from google.cloud import managedkafka_v1
from google.cloud.managedkafka_v1.services.managed_kafka_connect import (
    ManagedKafkaConnectClient,
)
from google.api_core.exceptions import GoogleAPICallError

# TODO(developer)
# project_id = "my-project-id"
# region = "us-central1"

connect_client = ManagedKafkaConnectClient()

request = managedkafka_v1.ListConnectClustersRequest(
    parent=connect_client.common_location_path(project_id, region),
)

response = connect_client.list_connect_clusters(request=request)
for cluster in response:
    try:
        print("Got Connect cluster:", cluster)
    except GoogleAPICallError as e:
        print(f"Failed to list Connect clusters with error: {e}")

Passaggi successivi

Apache Kafka® è un marchio registrato di Apache Software Foundation o delle sue società affiliate negli Stati Uniti e/o in altri paesi.

Elenca i cluster di connessione Mantieni tutto organizzato con le raccolte Salva e classifica i contenuti in base alle tue preferenze.