Eseguire la migrazione di schema e dati da Teradata

La combinazione di BigQuery Data Transfer Service e di un agente di migrazione speciale consente di copiare i dati da un'istanza di data warehouse on-premise di Teradata in BigQuery. Questo documento descrive il processo dettagliato della migrazione dei dati da Teradata utilizzando BigQuery Data Transfer Service.

Prima di iniziare

  1. Accedi al tuo account Google Cloud. Se non conosci Google Cloud, crea un account per valutare le prestazioni dei nostri prodotti in scenari reali. I nuovi clienti ricevono anche 300 $di crediti gratuiti per l'esecuzione, il test e il deployment dei carichi di lavoro.
  2. Nella pagina del selettore di progetti della console Google Cloud, seleziona o crea un progetto Google Cloud.

    Vai al selettore progetti

  3. Assicurati che la fatturazione sia attivata per il tuo progetto Google Cloud.

  4. Abilita le API BigQuery, BigQuery Data Transfer Service, Cloud Storage, and Pub/Sub.

    Abilita le API

  5. Crea un account di servizio:

    1. Nella console Google Cloud, vai alla pagina Crea account di servizio.

      Vai a Crea account di servizio
    2. Seleziona il progetto.
    3. Nel campo Nome account di servizio, inserisci un nome. La console Google Cloud compila il campo ID account di servizio in base a questo nome.

      Nel campo Descrizione account di servizio, inserisci una descrizione. Ad esempio, Service account for quickstart.

    4. Fai clic su Crea e continua.
    5. Concedi i seguenti ruoli all'account di servizio: roles/bigquery.user, roles/storage.objectAdmin, roles/iam.serviceAccountTokenCreator.

      Per concedere un ruolo, trova l'elenco Seleziona un ruolo e selezionalo.

      Per concedere altri ruoli, fai clic su Aggiungi un altro ruolo e aggiungi ogni ruolo aggiuntivo.

    6. Fai clic su Continua.
    7. Fai clic su Fine per completare la creazione dell'account di servizio.

      Non chiudere la finestra del browser. La utilizzerai nel passaggio successivo.

  6. Crea una chiave dell'account di servizio:

    1. Nella console Google Cloud, fai clic sull'indirizzo email dell'account di servizio che hai creato.
    2. Fai clic su Chiavi.
    3. Fai clic su Aggiungi chiave, quindi su Crea nuova chiave.
    4. Fai clic su Crea. Un file della chiave JSON viene scaricato sul computer.
    5. Fai clic su Chiudi.
  7. Nella pagina del selettore di progetti della console Google Cloud, seleziona o crea un progetto Google Cloud.

    Vai al selettore progetti

  8. Assicurati che la fatturazione sia attivata per il tuo progetto Google Cloud.

  9. Abilita le API BigQuery, BigQuery Data Transfer Service, Cloud Storage, and Pub/Sub.

    Abilita le API

  10. Crea un account di servizio:

    1. Nella console Google Cloud, vai alla pagina Crea account di servizio.

      Vai a Crea account di servizio
    2. Seleziona il progetto.
    3. Nel campo Nome account di servizio, inserisci un nome. La console Google Cloud compila il campo ID account di servizio in base a questo nome.

      Nel campo Descrizione account di servizio, inserisci una descrizione. Ad esempio, Service account for quickstart.

    4. Fai clic su Crea e continua.
    5. Concedi i seguenti ruoli all'account di servizio: roles/bigquery.user, roles/storage.objectAdmin, roles/iam.serviceAccountTokenCreator.

      Per concedere un ruolo, trova l'elenco Seleziona un ruolo e selezionalo.

      Per concedere altri ruoli, fai clic su Aggiungi un altro ruolo e aggiungi ogni ruolo aggiuntivo.

    6. Fai clic su Continua.
    7. Fai clic su Fine per completare la creazione dell'account di servizio.

      Non chiudere la finestra del browser. La utilizzerai nel passaggio successivo.

  11. Crea una chiave dell'account di servizio:

    1. Nella console Google Cloud, fai clic sull'indirizzo email dell'account di servizio che hai creato.
    2. Fai clic su Chiavi.
    3. Fai clic su Aggiungi chiave, quindi su Crea nuova chiave.
    4. Fai clic su Crea. Un file della chiave JSON viene scaricato sul computer.
    5. Fai clic su Chiudi.
  12. La chiave scaricata ha il seguente formato:

    {
      "type": "service_account",
      "project_id": "PROJECT_ID",
      "private_key_id": "KEY_ID",
      "private_key": "-----BEGIN PRIVATE KEY-----\nPRIVATE_KEY\n-----END PRIVATE KEY-----\n",
      "client_email": "SERVICE_ACCOUNT_EMAIL",
      "client_id": "CLIENT_ID",
      "auth_uri": "https://accounts.google.com/o/oauth2/auth",
      "token_uri": "https://accounts.google.com/o/oauth2/token",
      "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
      "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/SERVICE_ACCOUNT_EMAIL"
    }
    

    Assicurati di archiviare la chiave in modo sicuro perché può essere utilizzata per l'autenticazione come account di servizio. Puoi spostare e rinominare questo file se necessario.

Imposta le autorizzazioni richieste

Assicurati che l'entità che crea il trasferimento abbia i ruoli seguenti nel progetto contenente il job di trasferimento:

  • Visualizzatore log (roles/logging.viewer)
  • Amministratore Storage (roles/storage.admin) o un ruolo personalizzato che concede le seguenti autorizzazioni:
    • storage.objects.create
    • storage.objects.get
    • storage.objects.list
  • Amministratore BigQuery (roles/bigquery.admin) o un ruolo personalizzato che concede le seguenti autorizzazioni:
    • bigquery.datasets.create
    • bigquery.jobs.create
    • bigquery.jobs.get
    • bigquery.jobs.listAll
    • bigquery.transfers.get
    • bigquery.transfers.update

crea un set di dati

Crea un set di dati BigQuery per archiviare i tuoi dati. Non è necessario creare tabelle.

crea un bucket Cloud Storage

Crea un bucket Cloud Storage per la gestione temporanea dei dati durante il job di trasferimento.

prepara l'ambiente locale

Completa le attività in questa sezione per preparare il tuo ambiente locale per il job di trasferimento.

Requisiti delle macchine locali

  • L'agente di migrazione utilizza una connessione JDBC con l'istanza Teradata e le API Google Cloud. Assicurati che l'accesso alla rete non sia bloccato da un firewall.
  • Assicurati che sia installato Java Runtime Environment 8 o versione successiva.
  • Assicurati di avere spazio di archiviazione sufficiente per il metodo di estrazione che hai scelto, come descritto in Metodo di estrazione.
  • Se hai deciso di utilizzare l'estrazione con Teradata Parallel Transporter (TPT), assicurati che l'utilità tbuild sia installata. Per ulteriori informazioni sulla scelta di un metodo di estrazione, consulta Metodo di estrazione.

Dettagli connessione Teradata

  • Assicurati di disporre del nome utente e della password di un utente Teradata con accesso in lettura alle tabelle di sistema e a quelle di cui viene eseguita la migrazione.

  • Assicurati di conoscere il nome host e il numero di porta per la connessione all'istanza Teradata.

Scarica il driver JDBC

Scarica il file del driver JDBC di terajdbc4.jar da Teradata su una macchina in grado di connettersi al data warehouse.

Imposta la variabile GOOGLE_APPLICATION_CREDENTIALS

Imposta la variabile di ambiente GOOGLE_APPLICATION_CREDENTIALS sulla chiave dell'account di servizio che hai scaricato nella sezione Prima di iniziare.

Aggiorna la regola in uscita di Controlli di servizio VPC

Aggiungi un progetto Google Cloud gestito da BigQuery Data Transfer Service (numero di progetto: 990232121269) alla regola in uscita nel perimetro dei Controlli di servizio VPC.

Il canale di comunicazione tra l'agente in esecuzione on-premise e BigQuery Data Transfer Service pubblica messaggi Pub/Sub in un argomento per trasferimento. BigQuery Data Transfer Service deve inviare comandi all'agente per estrarre i dati e l'agente deve pubblicare i messaggi in BigQuery Data Transfer Service per aggiornare lo stato e restituire le risposte all'estrazione dei dati.

Creare un file di schema personalizzato

Per utilizzare un file di schema personalizzato invece del rilevamento automatico dello schema, creane uno manualmente o fai in modo che l'agente di migrazione ne crei uno per te quando inizializzi l'agente.

Se crei manualmente un file di schema e intendi utilizzare la console Google Cloud per creare un trasferimento, caricalo in un bucket Cloud Storage nello stesso progetto che prevedi di utilizzare per il trasferimento.

Scarica l'agente di migrazione

Scarica l'agente di migrazione su una macchina in grado di connettersi al data warehouse. Sposta il file JAR dell'agente di migrazione nella stessa directory in cui si trova il file JAR del driver JDBC di Teradata.

Configura un trasferimento

Crea un trasferimento con BigQuery Data Transfer Service.

Se vuoi creare automaticamente un file di schema personalizzato, utilizza l'agente di migrazione per configurare il trasferimento.

Non puoi creare un trasferimento on demand utilizzando lo strumento a riga di comando bq. Devi utilizzare la console Google Cloud o l'API BigQuery Data Transfer Service.

Se stai creando un trasferimento ricorrente, ti consigliamo vivamente di specificare un file di schema in modo che i dati dei trasferimenti successivi possano essere partizionati correttamente quando vengono caricati in BigQuery. Senza un file di schema, BigQuery Data Transfer Service deduce lo schema della tabella dai dati di origine trasferiti e tutte le informazioni su partizionamento, clustering, chiavi primarie e monitoraggio delle modifiche andranno perse. Inoltre, i trasferimenti successivi saltano le tabelle di cui è stata eseguita la migrazione in precedenza dopo il trasferimento iniziale. Per scoprire di più su come creare un file di schema, consulta File di schema personalizzato.

Console

  1. Nella console Google Cloud, vai alla pagina BigQuery.

    Vai alla pagina di BigQuery

  2. Fai clic su Trasferimenti di dati.

  3. Fai clic su Crea trasferimento.

  4. Nella sezione Tipo di origine, procedi nel seguente modo:

    • Scegli Migrazione: Teradata.
    • In Nome configurazione di trasferimento, inserisci un nome visualizzato per il trasferimento, ad esempio My Migration. Il nome visualizzato può essere qualsiasi valore che ti consenta di identificare facilmente il trasferimento se devi modificarlo in seguito.
    • (Facoltativo) Per le Opzioni di pianificazione, puoi lasciare il valore predefinito Giornaliera (in base all'ora di creazione) o scegliere un'ora diversa se vuoi un trasferimento ricorrente e incrementale. In caso contrario, scegli On demand per un trasferimento una tantum.
    • In Impostazioni destinazione, scegli il set di dati appropriato.

      Nuova migrazione di Teradata generale.

  5. Nella sezione Dettagli origine dati, continua con i dettagli specifici per il trasferimento Teradata.

    • Per Tipo di database, scegli Teradata.
    • In Bucket Cloud Storage, cerca il nome del bucket Cloud Storage per la gestione temporanea dei dati di migrazione. Non digitare il prefisso gs://, inserisci solo il nome del bucket.
    • In Nome database, inserisci il nome del database di origine in Teradata.
    • In Pattern dei nomi tabella, inserisci un pattern per la corrispondenza dei nomi delle tabelle nel database di origine. Puoi usare espressioni regolari per specificare il pattern. Ad esempio:

      • sales|expenses corrisponde alle tabelle denominate sales e expenses.
      • .* corrisponde a tutte le tabelle.
    • In Email account di servizio, inserisci l'indirizzo email associato alle credenziali dell'account di servizio utilizzate da un agente di migrazione.

    • (Facoltativo) Se utilizzi un file di schema personalizzato, inserisci il percorso e il nome file del file nel campo Percorso file di schema. Se non fornisci un file di schema personalizzato, BigQuery rileva automaticamente lo schema della tabella utilizzando i dati di origine trasferiti. Puoi creare il tuo file di schema, come mostrato nell'immagine seguente, oppure puoi utilizzare l'agente di migrazione per creare un file di schema. Per informazioni sulla creazione di un file di schema, consulta Inizializzazione dell'agente di migrazione.

  6. Nel menu Account di servizio, seleziona un account di servizio tra quelli associati al tuo progetto Google Cloud. Puoi associare un account di servizio al trasferimento, anziché utilizzare le tue credenziali utente. Per ulteriori informazioni sull'utilizzo degli account di servizio con trasferimenti di dati, consulta Utilizzare gli account di servizio.

    • Se hai eseguito l'accesso con un'identità federata, è necessario un account di servizio per creare un trasferimento. Se hai eseguito l'accesso con un Account Google, un account di servizio per il trasferimento è facoltativo.
    • L'account di servizio deve disporre delle autorizzazioni richieste.
  7. (Facoltativo) Nella sezione Opzioni di notifica, segui questi passaggi:

    • Fai clic sul pulsante di attivazione/disattivazione Notifiche via email se vuoi che l'amministratore del trasferimento riceva una notifica via email quando un'esecuzione del trasferimento non va a buon fine.
    • Fai clic sul pulsante di attivazione/disattivazione Notifiche Pub/Sub per configurare le notifiche di esecuzione di Pub/Sub per il trasferimento. In Seleziona un argomento Pub/Sub, scegli il nome dell'argomento o fai clic su Crea un argomento.
  8. Fai clic su Salva.

  9. Nella pagina Dettagli trasferimento, fai clic sulla scheda Configurazione.

  10. Prendi nota del nome della risorsa per questo trasferimento, perché ne hai bisogno per eseguire l'agente di migrazione.

bq

Quando crei un trasferimento Cloud Storage utilizzando lo strumento bq, la configurazione del trasferimento è impostata in modo che si ripeta ogni 24 ore. Per i trasferimenti on demand, utilizza la console Google Cloud o l'API BigQuery Data Transfer Service.

Non puoi configurare le notifiche utilizzando lo strumento bq.

Inserisci il comando bq mk e fornisci il flag di creazione del trasferimento --transfer_config. Sono richiesti anche i seguenti flag:

  • --data_source
  • --display_name
  • --target_dataset
  • --params
bq mk \
--transfer_config \
--project_id=project ID \
--target_dataset=dataset \
--display_name=name \
--service_account_name=service_account \
--params='parameters' \
--data_source=data source

Dove:

  • project ID è l'ID progetto. Se --project_id non viene fornito per specificare un progetto specifico, viene utilizzato il progetto predefinito.
  • dataset è il set di dati che vuoi scegliere come target (--target_dataset) per la configurazione di trasferimento.
  • name è il nome visualizzato (--display_name) per la configurazione del trasferimento. Il nome visualizzato del trasferimento può essere qualsiasi valore che ti consenta di identificare il trasferimento se devi modificarlo in un secondo momento.
  • service_account è il nome dell'account di servizio utilizzato per autenticare il trasferimento. L'account di servizio deve essere di proprietà dello stesso project_id utilizzato per creare il trasferimento e deve avere tutte le autorizzazioni richieste elencate.
  • parameters contiene i parametri (--params) per la configurazione di trasferimento creata in formato JSON. Ad esempio: --params='{"param":"param_value"}'.
    • Per le migrazioni di Teradata, utilizza i seguenti parametri:
      • bucket è il bucket Cloud Storage che fungerà da area temporanea durante la migrazione.
      • database_type è Teradata.
      • agent_service_account è l'indirizzo email associato all'account di servizio che hai creato.
      • database_name è il nome del database di origine in Teradata.
      • table_name_patterns è uno o più pattern per la corrispondenza dei nomi delle tabelle nel database di origine. Puoi usare espressioni regolari per specificare il pattern. Il pattern deve seguire la sintassi di espressione regolare Java. Ad esempio:
        • sales|expenses corrisponde alle tabelle denominate sales e expenses.
        • .* corrisponde a tutte le tabelle.
  • data_source è l'origine dati (--data_source): on_premises.

Ad esempio, il seguente comando crea un trasferimento Teradata denominato My Transfer utilizzando il bucket Cloud Storage mybucket e il set di dati di destinazione mydataset. Il trasferimento eseguirà la migrazione di tutte le tabelle dal data warehouse di Teradata mydatabase e il file di schema facoltativo è myschemafile.json.

bq mk \
--transfer_config \
--project_id=123456789876 \
--target_dataset=MyDataset \
--display_name='My Migration' \
--params='{"bucket": "mybucket", "database_type": "Teradata",
"database_name":"mydatabase", "table_name_patterns": ".*",
"agent_service_account":"myemail@mydomain.com", "schema_file_path":
"gs://mybucket/myschemafile.json"}' \
--data_source=on_premises

Dopo aver eseguito il comando, viene visualizzato un messaggio simile al seguente:

[URL omitted] Please copy and paste the above URL into your web browser and follow the instructions to retrieve an authentication code.

Segui le istruzioni e incolla il codice di autenticazione nella riga di comando.

API

Utilizza il metodo projects.locations.transferConfigs.create e fornisci un'istanza della risorsa TransferConfig.

Java

Prima di provare questo esempio, segui le istruzioni di configurazione di Java disponibili nella guida rapida di BigQuery sull'utilizzo delle librerie client. Per saperne di più, consulta la documentazione di riferimento dell'API BigQuery Java.

Per eseguire l'autenticazione in BigQuery, configura Credenziali predefinite dell'applicazione. Per maggiori informazioni, consulta Configurare l'autenticazione per le librerie client.

import com.google.api.gax.rpc.ApiException;
import com.google.cloud.bigquery.datatransfer.v1.CreateTransferConfigRequest;
import com.google.cloud.bigquery.datatransfer.v1.DataTransferServiceClient;
import com.google.cloud.bigquery.datatransfer.v1.ProjectName;
import com.google.cloud.bigquery.datatransfer.v1.TransferConfig;
import com.google.protobuf.Struct;
import com.google.protobuf.Value;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

// Sample to create a teradata transfer config.
public class CreateTeradataTransfer {

  public static void main(String[] args) throws IOException {
    // TODO(developer): Replace these variables before running the sample.
    final String projectId = "MY_PROJECT_ID";
    String datasetId = "MY_DATASET_ID";
    String databaseType = "Teradata";
    String bucket = "cloud-sample-data";
    String databaseName = "MY_DATABASE_NAME";
    String tableNamePatterns = "*";
    String serviceAccount = "MY_SERVICE_ACCOUNT";
    String schemaFilePath = "/your-schema-path";
    Map<String, Value> params = new HashMap<>();
    params.put("database_type", Value.newBuilder().setStringValue(databaseType).build());
    params.put("bucket", Value.newBuilder().setStringValue(bucket).build());
    params.put("database_name", Value.newBuilder().setStringValue(databaseName).build());
    params.put("table_name_patterns", Value.newBuilder().setStringValue(tableNamePatterns).build());
    params.put("agent_service_account", Value.newBuilder().setStringValue(serviceAccount).build());
    params.put("schema_file_path", Value.newBuilder().setStringValue(schemaFilePath).build());
    TransferConfig transferConfig =
        TransferConfig.newBuilder()
            .setDestinationDatasetId(datasetId)
            .setDisplayName("Your Teradata Config Name")
            .setDataSourceId("on_premises")
            .setParams(Struct.newBuilder().putAllFields(params).build())
            .setSchedule("every 24 hours")
            .build();
    createTeradataTransfer(projectId, transferConfig);
  }

  public static void createTeradataTransfer(String projectId, TransferConfig transferConfig)
      throws IOException {
    try (DataTransferServiceClient client = DataTransferServiceClient.create()) {
      ProjectName parent = ProjectName.of(projectId);
      CreateTransferConfigRequest request =
          CreateTransferConfigRequest.newBuilder()
              .setParent(parent.toString())
              .setTransferConfig(transferConfig)
              .build();
      TransferConfig config = client.createTransferConfig(request);
      System.out.println("Cloud teradata transfer created successfully :" + config.getName());
    } catch (ApiException ex) {
      System.out.print("Cloud teradata transfer was not created." + ex.toString());
    }
  }
}

Agente di migrazione

Facoltativamente, puoi configurare il trasferimento direttamente dall'agente di migrazione. Per maggiori informazioni, consulta Inizializzare l'agente di migrazione.

Inizializza l'agente di migrazione

Devi inizializzare l'agente di migrazione per un nuovo trasferimento. L'inizializzazione è necessaria una sola volta per un trasferimento, indipendentemente dal fatto che sia ricorrente o meno. L'inizializzazione configura solo l'agente di migrazione e non avvia il trasferimento.

Se intendi utilizzare l'agente di migrazione per creare un file di schema personalizzato, assicurati di avere nella directory di lavoro una directory scrivibile con lo stesso nome del progetto che vuoi utilizzare per il trasferimento. È qui che l'agente di migrazione crea il file di schema. Ad esempio, se lavori in /home e stai configurando il trasferimento nel progetto myProject, crea la directory /home/myProject e assicurati che sia scrivibile dagli utenti.

  1. Apri una nuova sessione. Nella riga di comando, invia il comando di inizializzazione, che segue questo modulo:

    java -cp \
    OS-specific-separated-paths-to-jars (JDBC and agent) \
    com.google.cloud.bigquery.dms.Agent \
    --initialize
    

    L'esempio seguente mostra il comando di inizializzazione quando i file JAR del driver JDBC e dell'agente di migrazione si trovano in una directory migration locale:

    Unix, Linux, Mac OS

    java -cp \
    /usr/local/migration/terajdbc4.jar:/usr/local/migration/mirroring-agent.jar \
    com.google.cloud.bigquery.dms.Agent \
    --initialize
    

    Windows

    Copia tutti i file nella cartella C:\migration (o modifica i percorsi nel comando), quindi esegui:

    java -cp C:\migration\terajdbc4.jar;C:\migration\mirroring-agent.jar com.google.cloud.bigquery.dms.Agent --initialize
    
  2. Quando richiesto, configura le seguenti opzioni:

    1. Scegli se salvare il modello Teradata Parallel Transporter (TPT) su disco. Se prevedi di utilizzare il metodo di estrazione del TPT, puoi modificare il modello salvato con parametri adatti alla tua istanza di Teradata.
    2. Digita il percorso di una directory locale che il job di trasferimento può utilizzare per l'estrazione dei file. Assicurati di avere lo spazio di archiviazione minimo consigliato, come descritto in Metodo di estrazione.
    3. Digita il nome host del database.
    4. Digita la porta del database.
    5. Scegli se utilizzare Teradata Parallel Transporter (TPT) come metodo di estrazione.
    6. (Facoltativo) Digita il percorso di un file delle credenziali del database.
    7. Scegli se specificare un nome per la configurazione di BigQuery Data Transfer Service.

      Se stai inizializzando l'agente di migrazione per un trasferimento che hai già configurato, procedi nel seguente modo:

      1. Digita il nome della risorsa del trasferimento. Puoi trovarlo nella scheda Configurazione della pagina Dettagli trasferimento relativa al trasferimento.
      2. Quando richiesto, digita un percorso e un nome file per il file di configurazione dell'agente di migrazione che verrà creato. Fai riferimento a questo file quando esegui l'agente di migrazione per avviare il trasferimento.
      3. Salta i passaggi rimanenti.

      Se utilizzi l'agente di migrazione per configurare un trasferimento, premi Invio per passare al prompt successivo.

    8. Digita l'ID progetto Google Cloud.

    9. Digita il nome del database di origine in Teradata.

    10. Digita un pattern per la corrispondenza dei nomi delle tabelle nel database di origine. Puoi utilizzare espressioni regolari per specificare il pattern. Ad esempio:

      • sales|expenses corrisponde alle tabelle denominate sales e expenses.
      • .* corrisponde a tutte le tabelle.
    11. (Facoltativo) Digita il percorso di un file di schema JSON locale. Questa opzione è vivamente consigliata per i trasferimenti ricorrenti.

      Se non utilizzi un file di schema o se vuoi che l'agente di migrazione ne crei uno per te, premi Invio per passare al prompt successivo.

    12. Scegli se creare un nuovo file di schema.

      Se vuoi creare un file di schema:

      1. Digita yes.
      2. Digita il nome utente di un utente Teradata che ha accesso in lettura alle tabelle di sistema e alle tabelle di cui vuoi eseguire la migrazione.
      3. Digita la password per l'utente.

        L'agente di migrazione crea il file di schema e ne restituisce la posizione.

      4. Modifica il file dello schema per contrassegnare il partizionamento, il clustering, le chiavi primarie e le colonne di monitoraggio delle modifiche e verifica di voler utilizzare questo schema per la configurazione del trasferimento. Per suggerimenti, consulta File di schema personalizzato.

      5. Premi Enter per passare al prompt successivo.

      Se non vuoi creare un file di schema, digita no.

    13. Digita il nome del bucket Cloud Storage di destinazione per la gestione temporanea dei dati sulla migrazione prima del caricamento in BigQuery. Se l'agente di migrazione ha creato un file di schema personalizzato, anche questo viene caricato in questo bucket.

    14. Digita il nome del set di dati di destinazione in BigQuery.

    15. Digita un nome visualizzato per la configurazione di trasferimento.

    16. Digita un percorso e un nome file per il file di configurazione dell'agente di migrazione che verrà creato.

  3. Dopo aver inserito tutti i parametri richiesti, l'agente di migrazione crea un file di configurazione e lo genera nel percorso locale specificato. Consulta la prossima sezione per esaminare più nel dettaglio il file di configurazione.

File di configurazione per l'agente di migrazione

Il file di configurazione creato nel passaggio di inizializzazione è simile al seguente esempio:


{
  "agent-id": "81f452cd-c931-426c-a0de-c62f726f6a6f",
  "transfer-configuration": {
    "project-id": "123456789876",
    "location": "us",
    "id": "61d7ab69-0000-2f6c-9b6c-14c14ef21038"
  },
  "source-type": "teradata",
  "console-log": false,
  "silent": false,
  "teradata-config": {
    "connection": {
      "host": "localhost"
    },
    "local-processing-space": "extracted",
    "database-credentials-file-path": "",
    "max-local-storage": "50GB",
    "gcs-upload-chunk-size": "32MB",
    "use-tpt": true,
    "transfer-views": false,
    "max-sessions": 0,
    "spool-mode": "NoSpool",
    "max-parallel-upload": 4,
    "max-parallel-extract-threads": 1,
    "session-charset": "UTF8",
    "max-unload-file-size": "2GB"
  }
}
   

Opzioni del job di trasferimento nel file di configurazione dell'agente di migrazione

  • transfer-configuration: informazioni su questa configurazione di trasferimento in BigQuery.
  • teradata-config: informazioni specifiche per questa estrazione di Teradata:

    • connection: informazioni sul nome host e sulla porta
    • local-processing-space: la cartella di estrazione in cui l'agente estrarrà i dati della tabella, prima di caricarli in Cloud Storage.
    • database-credentials-file-path: (facoltativo) il percorso di un file contenente le credenziali per la connessione automatica al database Teradata. Il file deve contenere due righe per le credenziali. Puoi usare un nome utente e una password, come mostrato nell'esempio seguente:
      username=abc
      password=123
      
      In alternativa, puoi utilizzare un secret di SecretManager:
      username=abc
      secret_resource_id=projects/my-project/secrets/my-secret-name/versions/1
      
      Quando utilizzi un file delle credenziali, assicurati di controllare l'accesso alla cartella in cui lo archivi nel file system locale, perché non verrà crittografata. Se non viene fornito alcun percorso, ti verrà chiesto di inserire nome utente e password quando avvii un agente.
    • max-local-storage: la quantità massima di spazio di archiviazione locale da utilizzare per l'estrazione nella directory temporanea specificata. Il valore predefinito è 50GB. Il formato supportato è: numberKB|MB|GB|TB.

      In tutte le modalità di estrazione, i file vengono eliminati dalla directory temporanea locale dopo essere stati caricati in Cloud Storage.

    • use-tpt: indica all'agente di migrazione di utilizzare Teradata Parallel Transporter (TPT) come metodo di estrazione.

      Per ogni tabella, l'agente di migrazione genera uno script TPT, avvia un processo tbuild e attende il completamento. Una volta completato il processo tbuild, l'agente elenca e carica i file estratti in Cloud Storage, quindi elimina lo script TPT. Per ulteriori informazioni, consulta Metodo di estrazione.

    • transfer-views: indica all'agente di migrazione di trasferire anche i dati dalle viste. Utilizza questa opzione solo quando richiedi la personalizzazione dei dati durante la migrazione. In altri casi, esegui la migrazione delle viste a Visualizzazioni BigQuery. Questa opzione ha i seguenti prerequisiti:

      • Puoi utilizzare questa opzione solo con Teradata versione 16.10 e successive.
      • Una vista deve avere una colonna "partizione" intera definita che punta a un ID di partizione per la riga specificata nella tabella sottostante.
    • max-sessions: specifica il numero massimo di sessioni utilizzato dal job di esportazione (FastExport o TPT). Se impostato su 0, il database Teradata determinerà il numero massimo di sessioni per ogni job di esportazione.

    • gcs-upload-chunk-size: un file di grandi dimensioni viene caricato in Cloud Storage in blocchi. Questo parametro, insieme a max-parallel-upload, vengono usati per controllare contemporaneamente la quantità di dati caricati in Cloud Storage. Ad esempio, se gcs-upload-chunk-size è 64 MB e max-parallel-upload è 10 MB, in teoria un agente di migrazione può caricare 640 MB (64 MB * 10) di dati contemporaneamente. Se il caricamento del blocco non riesce, sarà necessario riprovare l'intero blocco. La dimensione del blocco deve essere ridotta.

    • max-parallel-upload: questo valore determina il numero massimo di thread utilizzati dall'agente di migrazione per caricare file in Cloud Storage. Se non specificato, il valore predefinito corrisponde al numero di processori disponibili per la macchina virtuale Java. Come regola generale, scegli il valore in base al numero di core presenti nella macchina che esegue l'agente. Quindi se hai n core, il numero ottimale di thread dovrebbe essere n. Se i core sono hyperthreaded, il numero ottimale dovrebbe essere (2 * n). Durante la regolazione di max-parallel-upload è necessario considerare anche altre impostazioni, come la larghezza di banda di rete. La modifica di questo parametro può migliorare le prestazioni del caricamento su Cloud Storage.

    • spool-mode : nella maggior parte dei casi, la modalità NoSpool è l'opzione migliore. NoSpool è il valore predefinito nella configurazione dell'agente. Puoi modificare questo parametro nel caso in cui al tuo caso si applichino eventuali svantaggi di NoSpool.

    • max-unload-file-size: determina la dimensione massima del file estratto. Questo parametro non viene applicato per le estrazioni TPT.

    • max-parallel-extract-threads: questa configurazione viene utilizzata solo in modalità FastExport. Determina il numero di thread paralleli utilizzati per l'estrazione dei dati da Teradata. La modifica di questo parametro potrebbe migliorare le prestazioni dell'estrazione.

    • tpt-template-path: utilizza questa configurazione per fornire uno script di estrazione del TPT personalizzato come input. Puoi utilizzare questo parametro per applicare le trasformazioni ai dati di migrazione.

    • schema-mapping-rule-path: (facoltativo) il percorso di un file di configurazione contenente una mappatura dello schema per sostituire le regole di mappatura predefinite. Alcuni tipi di mappatura funzionano solo con la modalità Teradata Parallel Transporter (TPT).

      Esempio: mappatura dal tipo Teradata TIMESTAMP al tipo BigQuery DATETIME:

      {
      "rules": [
        {
          "database": {
              "name": "database.*",
              "tables": [
                 {
                   "name": "table.*"
                 }
              ]
          },
          "match": {
            "type": "COLUMN_TYPE",
            "value": "TIMESTAMP"
          },
          "action": {
            "type": "MAPPING",
            "value": "DATETIME"
          }
        }
      ]
      }
      

      Attributi:

      • database: (facoltativo) name è un'espressione regolare per i database da includere. Tutti i database sono inclusi per impostazione predefinita.
      • tables: (facoltativo) contiene un array di tabelle. name è un'espressione regolare per le tabelle da includere. Tutte le tabelle sono incluse per impostazione predefinita.
      • match: (obbligatorio)
        • type valori supportati: COLUMN_TYPE.
        • Valori supportati per value: TIMESTAMP, DATETIME.
      • action: (obbligatorio)
        • type valori supportati: MAPPING.
        • Valori supportati per value: TIMESTAMP, DATETIME.
    • compress-output: (facoltativo) indica se i dati devono essere compressi prima dell'archiviazione in Cloud Storage. Viene applicato solo in tpt-mode. Per impostazione predefinita, questo valore è false.

Esegui l'agente di migrazione

Dopo aver inizializzato l'agente di migrazione e creato il file di configurazione, segui questi passaggi per eseguire l'agente e avviare la migrazione:

  1. Esegui l'agente specificando i percorsi del driver JDBC, dell'agente di migrazione e del file di configurazione creato nel passaggio di inizializzazione precedente.

    java -cp \
    OS-specific-separated-paths-to-jars (JDBC and agent) \
    com.google.cloud.bigquery.dms.Agent \
    --configuration-file=path to configuration file
    

    Unix, Linux, Mac OS

    java -cp \
    /usr/local/migration/Teradata/JDBC/terajdbc4.jar:mirroring-agent.jar \
    com.google.cloud.bigquery.dms.Agent \
    --configuration-file=config.json
    

    Windows

    Copia tutti i file nella cartella C:\migration (o modifica i percorsi nel comando), quindi esegui:

    java -cp C:\migration\terajdbc4.jar;C:\migration\mirroring-agent.jar com.google.cloud.bigquery.dms.Agent --configuration-file=config.json
    

    Se è tutto pronto per procedere con la migrazione, premi Enter e l'agente procederà se il classpath fornito durante l'inizializzazione è valido.

  2. Quando richiesto, digita il nome utente e la password per la connessione al database. Se il nome utente e la password sono validi, viene avviata la migrazione dei dati.

    Facoltativo Nel comando per avviare la migrazione, puoi anche utilizzare un flag che trasmette un file delle credenziali all'agente, invece di inserire ogni volta il nome utente e la password. Per saperne di più, consulta il parametro facoltativo database-credentials-file-path nel file di configurazione dell'agente. Quando utilizzi un file delle credenziali, adotta le misure appropriate per controllare l'accesso alla cartella in cui lo archivi nel file system locale, perché non sarà criptata.

  3. Lascia aperta questa sessione fino al completamento della migrazione. Se hai creato un trasferimento di migrazione ricorrente, mantieni la sessione aperta a tempo indeterminato. Se questa sessione viene interrotta, le esecuzioni del trasferimento attuali e future non andranno a buon fine.

  4. Monitora periodicamente se l'agente è in esecuzione. Se è in corso un'esecuzione di trasferimento e nessun agente risponde entro 24 ore, l'esecuzione del trasferimento non va a buon fine.

  5. Se l'agente di migrazione smette di funzionare mentre il trasferimento è in corso o pianificato, la console Google Cloud mostra lo stato di errore e ti chiede di riavviare l'agente. Per avviare nuovamente l'agente di migrazione, riprendi dall'inizio di questa sezione eseguire l'agente di migrazione con il comando per eseguire l'agente di migrazione. Non è necessario ripetere il comando di inizializzazione. Il trasferimento riprende dal punto in cui le tabelle non sono state completate.

Monitorare l'avanzamento della migrazione

Puoi visualizzare lo stato della migrazione nella console Google Cloud. Puoi anche configurare Pub/Sub o notifiche email. Vedi Notifiche di BigQuery Data Transfer Service.

BigQuery Data Transfer Service pianifica e avvia l'esecuzione di un trasferimento in base a una pianificazione specificata al momento della creazione della configurazione del trasferimento. È importante che l'agente di migrazione sia in esecuzione quando è attiva un'esecuzione di trasferimento. Se non vengono ricevuti aggiornamenti dal lato agente entro 24 ore, l'esecuzione del trasferimento non va a buon fine.

Esempio dello stato della migrazione nella console Google Cloud:

Stato migrazione

Esegui l'upgrade dell'agente di migrazione

Se è disponibile una nuova versione dell'agente di migrazione, devi aggiornarlo manualmente. Per ricevere notifiche su BigQuery Data Transfer Service, iscriviti alle note di rilascio.

Passaggi successivi