Recupera i link di derivazione dei dati in più Google Cloud regioni utilizzando un approccio di distribuzione. Utilizzi l'API Data Lineage per recuperare e aggregare i dati di derivazione da tutte le regioni disponibili. Questa opzione è utile quando gli asset di dati sono distribuiti in diverse posizioni e hai bisogno di una visualizzazione unificata della loro provenienza.
Procedura
La procedura esegue richieste parallele all'endpoint projects.locations.searchLinks in ogni regione. Raccogli i risultati, gestisci la paginazione nelle varie regioni
e aggrega i link trovati. Gestisci un regionalPageToken per garantire una paginazione coerente
per le chiamate successive, tenendo conto delle regioni non raggiungibili.
Il seguente pseudocodice descrive una procedura che puoi seguire utilizzando l'API Data Lineage per recuperare i link di derivazione dei dati da tutte le regioni disponibili.
- Configurazione input:
linksToFetch= 5 (numero di link da recuperare da tutte le regioni)regionalPageToken= "" (ultimo token della pagina regionale ricevuto utilizzato per la paginazione)
- Crea:
- elenco di tutte le regioni in cui eseguire la distribuzione, chiamato
regions. - elenco di regioni non raggiungibili denominato
unreachable. - un elenco vuoto di link trovati chiamato
foundLinks. - una variabile vuota
nextPageTokenenextRegionalPageToken. - una variabile vuota
lastRegion. - una variabile vuota
lastRegionLinksCount.
- elenco di tutte le regioni in cui eseguire la distribuzione, chiamato
- Ordina
regionsin ordine alfabetico. - Analizza
regionalPageToken- Se è vuoto, vai al passaggio 5.
- Se non è vuoto, allora
- analizza
regionalPageTokendividendolo in due segmenti in base al primo punto - filtra le regioni prendendo solo quelle che si trovano dopo (in ordine alfabetico) il primo segmento di
regionalPageTokenanalizzato. - memorizza il secondo segmento per utilizzarlo in tutte le chiamate projects.locations.searchLinks.
- analizza
- Chiama projects.locations.searchLinks
in ogni regione dell'elenco
regionsin parallelo. - Attendi il completamento di tutte le richieste.
- Filtra le risposte riuscite e memorizza i nomi delle regioni non riuscite nell'elenco
unreachable. - Per ciascuna delle risposte (a partire dalla prima regione in ordine alfabetico)
- se non sono stati restituiti link insieme a un token di pagina non vuoto
- nome della regione del negozio in
lastRegion. - salva pageToken ricevuto in
nextPageToken. - ignora le risposte rimanenti.
- nome della regione del negozio in
- altrimenti
- nome della regione del negozio in
lastRegion. - salvare i link ricevuti in
foundLinks(fino alinksToFetch). - salva pageToken ricevuto in
nextPageToken. - memorizza il numero di link presi dalla risposta in
lastRegionLinksCount. - se
foundLinksè inferiore alinksToFetch- continua lo pseudocodice con la risposta successiva ricevuta in ordine alfabetico.
- se
foundLinksè uguale alinksToFetch- effettua un'altra richiesta all'endpoint projects.locations.searchLinks
nella stessa regione, ma imposta il parametro
pageSizesul valore dilastRegionLinksCount. - Il negozio ha ricevuto pageToken in
nextPageToken. - Vai al passaggio 9
- effettua un'altra richiesta all'endpoint projects.locations.searchLinks
nella stessa regione, ma imposta il parametro
- nome della regione del negozio in
- se non sono stati restituiti link insieme a un token di pagina non vuoto
- Anteponi
nextPageTokenalastRegion(ovvero[region].[receivedNextPageToken]) per crearenextRegionalPageTokenper gestire la paginazione nelle chiamate consecutive.