Aggiunta di tabelle di data lake a un’unità di condivisione dati

Sul producer crea uno schema esterno che faccia riferimento ai dati del data lake archiviati in Amazon S3. Lo schema esterno fa riferimento al Catalogo dati AWS Glue. Il ruolo e la Regione nell’esempio sono esempi:

CREATE EXTERNAL SCHEMA external_schema_name FROM DATA CATALOG
DATABASE 'glue_database_name'
IAM_ROLE 'arn:aws:iam::123456789012:role/sample-role'
REGION 'us-east-1';

Crea una tabelle di data lake nello schermo esterno.

CREATE EXTERNAL TABLE external_schema_name.sales(
salesid INTEGER,
sellerid INTEGER,
buyerid INTEGER,
saledate DATE,
pricepaid DECIMAL(8,2))
ROW FORMAT delimited
FIELDS TERMINATED BY '\t'
STORED AS textfile
LOCATION 's3://redshift-downloads/tickit/spectrum/sales/';

L’esempio include LOCATION. Deve essere nel formato s3://{bucket_name}/{folder}/, dove è specificata la cartella. La cartella deve essere lunga almeno un carattere. Facoltativamente puoi includere le sottocartelle. Per vedere altri esempi di creazione di tabelle in un data lake, consulta Esempi per CREATE EXTERNAL TABLE.

Crea una vista con associazione tardiva che faccia riferimento alla tabella esterna creata in precedenza:

CREATE VIEW lbv AS 
select * from external_schema_name.sales, other_schema.t1
WITH NO SCHEMA BINDING;

Aggiungi lo schema della vista all’unità di condivisione dati. Questo è lo schema locale che contiene la vista con associazione tardiva.

ALTER DATASHARE dsx_datashare ADD SCHEMA public;

Aggiungi lo schema che contiene la tabella a cui fa riferimento la vista con associazione tardiva all’unità di condivisione dati. L’aggiunta dello schema è necessaria per qualsiasi tabella di base a cui fai riferimento in una vista aggiunta a un’unità di condivisione dati, indipendentemente dal fatto che lo schema contenga oggetti di database locali oppure oggetti provenienti da un data lake. Tieni presente che devi aggiungere questo schema prima di aggiungere la vista con associazione tardiva.

ALTER DATASHARE dsx_datashare ADD SCHEMA external_schema_name;
ALTER DATASHARE dsx_datashare ADD SCHEMA other_schema;

Aggiungi la vista all’unità di condivisione dati utilizzando un comando SQL. Tieni presente che il nome della tabella include il prefisso dello schema.

ALTER DATASHARE my_datashare ADD TABLE public.lbv;

Conferma che la vista e gli schemi sono stati aggiunti correttamente all’unità di condivisione dati:

SELECT * FROM svv_datashare_objects WHERE share_name = 'my_datashare';

L’amministratore consumer crea un database dall’unità di condivisione dati e quindi ne concede l’utilizzo agli utenti consumer.

Crea uno schema esterno e una tabella esterna, come descritto nella prima sezione di questo argomento.

Scopri le tabelle esistenti nello schema esterno per confermare che la tabella che hai creato è disponibile:

SELECT * FROM svv_external_tables WHERE schemaname = 'external_schema_name';

Aggiungi lo schema esterno all’unità di condivisione dati:

ALTER DATASHARE my_datashare ADD SCHEMA external_schema_name;

Aggiungi la tabella esterna all’unità di condivisione dati. Tieni presente che il nome della tabella include il prefisso dello schema:

ALTER DATASHARE my_datashare ADD TABLE external_schema_name.sales;

Conferma che la tabella è stata aggiunta correttamente all’unità di condivisione dati:

SELECT * FROM svv_datashare_objects WHERE share_name = 'my_datashare';

Per istruzioni più dettagliate, consulta Condivisione dell’accesso in lettura ai dati all’interno di un account AWS.

Sul consumer, ossia il database che riceve i dati condivisi, l’amministratore associa l’unità di condivisione dati per rendere disponibili le tabelle condivise su cui gli utenti possono eseguire le query. Per ulteriori informazioni su come completare questa fase, consulta Gestione delle unità di condivisione dati da altri account in qualità di consumer.