Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
# Connettore Amazon Athena per Snowflake
Il connettore Amazon Athena per [Snowflake](https://www.snowflake.com/) consente ad Amazon Athena di eseguire query SQL sui dati archiviati nei database SQL Snowflake o sulle istanze RDS utilizzando JDBC.
Questo connettore può essere registrato con Catalogo Dati Glue come catalogo federato. Supporta i controlli di accesso ai dati definiti in Lake Formation a livello di catalogo, database, tabella, colonna, riga e tag. Questo connettore utilizza connessioni Glue per centralizzare le proprietà di configurazione in Glue.
## Prerequisiti
Implementa il connettore sul tuo Account AWS utilizzando la console Athena o `CreateDataCatalog` l'operazione API. Per ulteriori informazioni, consulta [Crea una connessione di un'origine dati](connect-to-a-data-source.md).
## Limitazioni
+ Le operazioni di scrittura DDL non sono supportate.
+ In una configurazione multiplex, il bucket di spill e il prefisso sono condivisi tra tutte le istanze del database.
+ Eventuali limiti Lambda pertinenti. Per ulteriori informazioni, consulta la sezione [Quote Lambda](https://docs.aws.amazon.com/lambda/latest/dg/gettingstarted-limits.html) nella *Guida per gli sviluppatori di AWS Lambda *.
+ Solo i connettori federati del catalogo dati Athena supportano la configurazione multiplexer.
+ Al momento, le viste di Snowflake non sono supportate.
+ In Snowflake, i nomi degli oggetti fanno distinzione tra maiuscole e minuscole. Athena accetta una combinazione di maiuscole e [minuscole](https://docs.aws.amazon.com/athena/latest/ug/tables-databases-columns-names.html#table-names-and-table-column-names-in-ate-must-be-lowercase) nelle query DDL e DML, ma per impostazione predefinita i nomi degli oggetti quando esegue la query. Il connettore Snowflake supporta solo lettere minuscole quando si utilizza Glue Catalog/Lake Formation. Quando viene utilizzato il catalogo Athena, i clienti possono controllare il comportamento del case utilizzando la variabile di ambiente `casing_mode` Lambda i cui valori possibili sono elencati nella [Parameters](#connectors-snowflake-parameters) sezione (ad esempio,). `key=casing_mode, value = CASE_INSENSITIVE_SEARCH`
## Termini
I seguenti termini si riferiscono al connettore Snowflake.
+ **Istanza del database**: qualsiasi istanza del database distribuita on-premise, su Amazon EC2 o su Amazon RDS.
+ **Gestore**: un gestore Lambda che accede all'istanza del database. Un gestore può gestire i metadati o i record di dati.
+ **Gestore dei metadati**: un gestore Lambda che recupera i metadati dall'istanza del database.
+ **Gestore dei record**: un gestore Lambda che recupera i record di dati dall'istanza del database.
+ **Gestore composito**: un gestore Lambda che recupera sia i metadati sia i record di dati dall'istanza del database.
+ **Proprietà o parametro**: una proprietà del database utilizzata dai gestori per estrarre le informazioni del database. Queste proprietà vengono configurate come variabili di ambiente Lambda.
+ **Stringa di connessione**: una stringa di testo utilizzata per stabilire una connessione a un'istanza del database.
+ **Catalogo**: un AWS Glue catalogo non registrato con Athena che è un prefisso obbligatorio per la proprietà. `connection_string`
+ **Gestore multiplex**: un gestore Lambda in grado di accettare e utilizzare più connessioni al database.
## Parameters
Utilizzate i parametri di questa sezione per configurare il connettore Snowflake.
### AWS Glue Data Catalog connettori federati
Si consiglia di configurare un connettore Snowflake utilizzando un oggetto Glue connections. Per fare ciò, imposta la variabile di `glue_connection` ambiente del connettore Snowflake Lambda sul nome della connessione Glue da utilizzare.
**Proprietà delle connessioni Glue**
Utilizzare il seguente comando per ottenere lo schema di un oggetto di connessione Glue. Questo schema contiene tutti i parametri che è possibile usare per controllare la connessione.
```
aws glue describe-connection-type --connection-type SNOWFLAKE
```
**Proprietà dell’ambiente Lambda**
Le seguenti proprietà dell'ambiente Lambda si applicano solo quando si utilizza il connettore con una funzione Lambda nel proprio account.
+ **glue\_connection**: specifica il nome della connessione Glue associata al connettore federato.
+ **casing\_mode**: (Facoltativo) specifica come gestire il casing per i nomi di schemi e tabelle. Il parametro `casing_mode` utilizza i seguenti valori per specificare il comportamento di casing:
+ **NESSUNA**: non modifica le maiuscole e minuscole dello schema e dei nomi delle tabelle specificati (esegui la query così com'è su Snowflake). Questo è il valore predefinito quando **casing\_mode** non è specificato.
+ **UPPER** — Tutti i nomi di schemi e tabelle indicati nella query prima di eseguirla su Snowflake.
+ **MINUSCOLO**: tutti i nomi di schemi e tabelle indicati nella query prima di eseguirla su Snowflake.
+ **CASE\_INSENSITIVE\_SEARCH — Esegue ricerche** senza distinzione tra maiuscole e minuscole nei nomi di schemi e tabelle in Snowflake. Ad esempio, puoi utilizzare questa modalità quando hai una query del tipo e Snowflake contiene una tabella chiamata. `SELECT * FROM EMPLOYEE` `Employee` Tuttavia, in presenza di conflitti tra nomi, ad esempio se viene chiamata una tabella `EMPLOYEE` e un'altra tabella `Employee` in Snowflake, la query avrà esito negativo.
**Nota**
Il connettore Snowflake creato utilizzando una connessione AWS Glue Data Catalog federata non supporta l'uso di un gestore di multiplazione.
Il connettore Snowflake creato utilizzando una connessione federata supporta solo 2. AWS Glue Data Catalog `ConnectionSchemaVersion`
**Memorizzazione delle credenziali**
Tutti i connettori che utilizzano una connessione AWS Glue Data Catalog federata devono Gestione dei segreti AWS memorizzare le credenziali. Per ulteriori informazioni, consulta [Autenticare con Snowflake](connectors-snowflake-authentication.md).
### Connettori federati del catalogo dati Athena
**Nota**
I connettori di origine dati Athena creati il 3 dicembre 2024 e versioni successive utilizzano connessioni. AWS Glue
I nomi e le definizioni dei parametri elencati di seguito si riferiscono ai connettori di origine dati Athena creati senza una connessione Glue associata. Utilizza i seguenti parametri solo quando [implementi manualmente](connect-data-source-serverless-app-repo.md) una versione precedente di un connettore di origine dati Athena o quando la proprietà dell’ambiente `glue_connection` non è specificata.
**Proprietà dell’ambiente**
+ **default**: la stringa di connessione JDBC da utilizzare per connettersi all’istanza del database Snowflake. Ad esempio, `snowflake://${jdbc_connection_string}`
+ **catalog\_connection\_string**: utilizzata dal gestore multiplexing (non supportata quando si utilizza una connessione Glue). Una stringa di connessione di un'istanza del database. Appone alla variabile di ambiente un prefisso con il nome del catalogo utilizzato in Athena. Ad esempio, se il catalogo registrato con Athena è mysnowflakecatalog, il nome della variabile di ambiente è mysnowflakecatalog\_connection\_string.
+ **casing\_mode**: (Facoltativo) specifica come gestire il casing per i nomi di schemi e tabelle. Il parametro `casing_mode` utilizza i seguenti valori per specificare il comportamento di casing:
+ **NESSUNO** — Non modifica le maiuscole e minuscole dello schema e dei nomi delle tabelle specificati (esegui la query così com'è su Snowflake). Questo è il valore predefinito quando **casing\_mode** non è specificato.
+ **UPPER** — Tutti i nomi di schemi e tabelle indicati nella query prima di eseguirla su Snowflake.
+ **MINUSCOLO**: tutti i nomi di schemi e tabelle indicati nella query prima di eseguirla su Snowflake.
+ **CASE\_INSENSITIVE\_SEARCH — Esegue ricerche** senza distinzione tra maiuscole e minuscole nei nomi di schemi e tabelle in Snowflake. Ad esempio, puoi utilizzare questa modalità quando hai una query del tipo e Snowflake contiene una tabella chiamata. `SELECT * FROM EMPLOYEE` `Employee` Tuttavia, in presenza di conflitti tra nomi, ad esempio se viene chiamata una tabella `EMPLOYEE` e un'altra tabella `Employee` in Snowflake, la query avrà esito negativo.
+ **spill\_bucket**: specifica il bucket Amazon S3 per i dati che superano i limiti della funzione Lambda.
+ **spill\_prefix**: (facoltativo) per impostazione predefinita, viene utilizzata una sottocartella nello `spill_bucket` specificato chiamata `athena-federation-spill`. Ti consigliamo di configurare un [ciclo di vita dell'archiviazione](https://docs.aws.amazon.com/AmazonS3/latest/userguide/object-lifecycle-mgmt.html) di Amazon S3 in questa posizione per eliminare gli spill più vecchi di un numero predeterminato di giorni o ore.
+ **spill\_put\_request\_headers**: (facoltativo) una mappa codificata in JSON delle intestazioni e dei valori della richiesta per la richiesta `putObject` di Amazon S3 utilizzata per lo spill (ad esempio, `{"x-amz-server-side-encryption" : "AES256"}`). Per altre possibili intestazioni, consulta il *riferimento [PutObject](https://docs.aws.amazon.com/AmazonS3/latest/API/API_PutObject.html)all'API di Amazon Simple Storage Service*.
+ **kms\_key\_id**: (facoltativo) per impostazione predefinita, tutti i dati riversati in Amazon S3 vengono crittografati utilizzando la modalità di crittografia autenticata AES-GCM e una chiave generata casualmente. Per fare in modo che la tua funzione Lambda utilizzi chiavi di crittografia più potenti generate da KMS come `a7e63k4b-8loc-40db-a2a1-4d0en2cd8331`, puoi specificare l'ID della chiave KMS.
+ **disable\_spill\_encryption**: (facoltativo) se impostato su `True`, disabilita la crittografia dello spill. L'impostazione predefinita è `False`: in questo modo, i dati riversati su S3 vengono crittografati utilizzando AES-GCM tramite una chiave generata casualmente o una chiave generata mediante KMS. La disabilitazione della crittografia dello spill può migliorare le prestazioni, soprattutto se la posizione dello spill utilizza la [crittografia lato server](https://docs.aws.amazon.com/AmazonS3/latest/userguide/serv-side-encryption.html).
#### Stringa di connessione
Utilizza una stringa di connessione JDBC nel formato seguente per connetterti a un'istanza del database.
```
snowflake://${{{jdbc_connection_string}}}
```
#### Utilizzo di un gestore multiplex
Puoi utilizzare un gestore multiplex per connetterti a più istanze del database con una singola funzione Lambda. Le richieste vengono indirizzate in base al nome del catalogo. Utilizza le seguenti classi in Lambda.
****
| Gestore | Classe |
| --- | --- |
| Gestore composito | SnowflakeMuxCompositeHandler |
| Gestore dei metadati | SnowflakeMuxMetadataHandler |
| Gestore dei record | SnowflakeMuxRecordHandler |
##### Parametri del gestore multiplex
****
| Parametro | Description |
| --- | --- |
| ${{catalog}}\_connection\_string | Obbligatorio. Una stringa di connessione di un'istanza del database. Appone alla variabile di ambiente un prefisso con il nome del catalogo utilizzato in Athena. Ad esempio, se il catalogo registrato presso Athena è mysnowflakecatalog, il nome della variabile di ambiente è mysnowflakecatalog\_connection\_string. |
| default | Obbligatorio. La stringa di connessione predefinita. Questa stringa viene utilizzata quando il catalogo è lambda:${ {{AWS\_LAMBDA\_FUNCTION\_NAME}}}. |
Le seguenti proprietà di esempio si riferiscono a una funzione Lambda Snowflake MUX che supporta due istanze del database: `snowflake1` (il valore predefinito) e `snowflake2`.
****
| Proprietà | Valore |
| --- | --- |
| default | snowflake://jdbc:snowflake://snowflake1.host:port/?warehouse=warehousename&db=db1&schema=schema1&${Test/RDS/Snowflake1} |
| snowflake\_catalog1\_connection\_string | snowflake://jdbc:snowflake://snowflake1.host:port/?warehouse=warehousename&db=db1&schema=schema1${Test/RDS/Snowflake1} |
| snowflake\_catalog2\_connection\_string | snowflake://jdbc:snowflake://snowflake2.host:port/?warehouse=warehousename&db=db1&schema=schema1&user=sample2&password=sample2 |
##### Specifica delle credenziali
Per fornire un nome utente e una password per il database nella stringa di connessione JDBC, puoi utilizzare le proprietà della stringa di connessione o Gestione dei segreti AWS.
+ **Stringa di connessione**: puoi specificare un nome utente e una password come proprietà nella stringa di connessione JDBC.
**Importante**
Come best practice di sicurezza, non utilizzare credenziali codificate nelle variabili di ambiente o nelle stringhe di connessione. *Per informazioni su come trasferire i segreti codificati in Gestione dei segreti AWS, consulta [Move i segreti codificati Gestione dei segreti AWS nella Guida per l'](https://docs.aws.amazon.com/secretsmanager/latest/userguide/hardcoded.html)utente.Gestione dei segreti AWS *
+ **Gestione dei segreti AWS**[— Per utilizzare la funzionalità Athena Federated Query con, Gestione dei segreti AWS il VPC collegato alla funzione Lambda deve avere [accesso a Internet o](https://aws.amazon.com/premiumsupport/knowledge-center/internet-access-lambda-function/) un endpoint VPC per connettersi a Secrets Manager.](https://docs.aws.amazon.com/secretsmanager/latest/userguide/vpc-endpoint-overview.html)
È possibile inserire il nome di un segreto nella Gestione dei segreti AWS stringa di connessione JDBC. Il connettore sostituisce il nome del segreto con i valori `username` e `password` di Secrets Manager.
Per le istanze del database Amazon RDS, questo supporto è strettamente integrato. Se usi Amazon RDS, ti consigliamo vivamente di utilizzare Gestione dei segreti AWS la rotazione delle credenziali. Se il tuo database non utilizza Amazon RDS, archivia le credenziali come JSON nel seguente formato:
```
{"username": "${username}", "password": "${password}"}
```
**Esempio di stringa di connessione con nome del segreto**
La stringa seguente ha il nome del segreto `${Test/RDS/Snowflake1}`.
```
snowflake://jdbc:snowflake://snowflake1.host:port/?warehouse=warehousename&db=db1&schema=schema1${Test/RDS/Snowflake1}&...
```
Il connettore utilizza il nome del segreto per recuperare i segreti e fornire il nome utente e la password, come nell'esempio seguente.
```
snowflake://jdbc:snowflake://snowflake1.host:port/warehouse=warehousename&db=db1&schema=schema1&user=sample2&password=sample2&...
```
Attualmente, Snowflake riconosce le proprietà JDBC `user` e `password`. Accetta anche il nome utente e la password nel formato {{username}} `/` {{password}} senza le chiavi `user` o. `password`
#### Utilizzo di un gestore a singola connessione
Puoi utilizzare i seguenti gestori di metadati e record a singola connessione per connetterti a una singola istanza Snowflake.
****
| Tipo di gestore | Classe |
| --- | --- |
| Gestore composito | SnowflakeCompositeHandler |
| Gestore dei metadati | SnowflakeMetadataHandler |
| Gestore dei record | SnowflakeRecordHandler |
##### Parametri del gestore a singola connessione
****
| Parametro | Description |
| --- | --- |
| default | Obbligatorio. La stringa di connessione predefinita. |
I gestori a singola connessione supportano una sola istanza del database e devono fornire un parametro di stringa di connessione del tipo `default`. Tutte le altre stringhe di connessione vengono ignorate.
La seguente proprietà di esempio si riferisce a una singola istanza Snowflake supportata da una funzione Lambda.
****
| Proprietà | Valore |
| --- | --- |
| default | snowflake://jdbc:snowflake://snowflake1.host:port/?secret=Test/RDS/Snowflake1 |
#### Parametri di spill
L'SDK Lambda può riversare i dati su Amazon S3. Tutte le istanze del database a cui accede la stessa funzione Lambda riversano i dati nella stessa posizione.
****
| Parametro | Description |
| --- | --- |
| spill\_bucket | Obbligatorio. Nome del bucket di spill. |
| spill\_prefix | Obbligatorio. Prefisso della chiave del bucket di spill. |
| spill\_put\_request\_headers | (Facoltativo) Una mappa codificata in JSON delle intestazioni e dei valori della richiesta per la richiesta putObject di Amazon S3 utilizzata per lo spill (ad esempio, {"x-amz-server-side-encryption" : "AES256"}). Per altre possibili intestazioni, consulta il riferimento [PutObject](https://docs.aws.amazon.com/AmazonS3/latest/API/API_PutObject.html)all'API di Amazon Simple Storage Service. |
## Supporto dei tipi di dati
Nella tabella seguente vengono illustrati i tipi di dati corrispondenti per JDBC e Apache Arrow.
****
| JDBC | Arrow |
| --- | --- |
| Booleano | Bit |
| Numero intero | Tiny |
| Breve | Smallint |
| Numero intero | Int |
| Long | Bigint |
| virgola mobile | Float4 |
| Double | Float8 |
| Data | DateDay |
| Time stamp | DateMilli |
| Stringa | Varchar |
| Byte | Varbinary |
| BigDecimal | Decimale |
| ARRAY | List |
## Conversioni dei tipi di dati
Oltre alle conversioni da JDBC ad Arrow, il connettore esegue alcune altre conversioni per rendere compatibili l'origine Snowflake e i tipi di dati Athena. Queste conversioni contribuiscono a garantire che le query vengano eseguite in modo corretto. Nella tabella seguente vengono illustrate queste conversioni.
****
| Tipo di dati di origine (Snowflake) | Tipo di dati convertito (Athena) |
| --- | --- |
| TIMESTAMP | TIMESTAMPMILLI |
| DATE | TIMESTAMPMILLI |
| INTEGER | INT |
| DECIMAL | BIGINT |
| TIMESTAMP\_NTZ | TIMESTAMPMILLI |
Tutti gli altri tipi di dati non supportati vengono convertiti in `VARCHAR`.
## Partizioni e suddivisioni
Le partizioni vengono utilizzate per determinare come generare suddivisioni per il connettore. Athena costruisce una colonna sintetica di tipo `varchar` che rappresenta lo schema di partizionamento della tabella per aiutare il connettore a generare suddivisioni. Il connettore non modifica la definizione effettiva della tabella.
Per creare questa colonna sintetica e le partizioni, Athena richiede la definizione di una chiave primaria. Tuttavia, poiché Snowflake non impone vincoli relativi alla chiave primaria, è necessario imporre l’unicità autonomamente. In caso contrario, Athena passerà automaticamente a una singola divisione.
## Performance
Per assicurare prestazioni ottimali, utilizza i filtri nelle query ogniqualvolta possibile. Inoltre, consigliamo vivamente di utilizzare il partizionamento nativo per recuperare set di dati di grandissime dimensioni con una distribuzione uniforme delle partizioni. La selezione di un sottoinsieme di colonne velocizza notevolmente il runtime delle query e riduce i dati scansionati. Il connettore Snowflake è resiliente alla limitazione della larghezza di banda della rete dovuta alla simultaneità.
Il connettore Athena Snowflake esegue il pushdown dei predicati per ridurre i dati scansionati dalla query. Le clausole `LIMIT`, i predicati semplici e le espressioni complesse vengono inviati al connettore per ridurre la quantità di dati scansionati e per ridurre il tempo di esecuzione delle query.
### Clausole LIMIT
Una dichiarazione `LIMIT N` riduce la quantità di dati analizzati dalla query. Con il pushdown `LIMIT N`, il connettore restituisce solo le righe `N` ad Athena.
### Predicati
Un predicato è un'espressione nella clausola `WHERE` di una query SQL che valuta a un valore booleano e filtra le righe in base a più condizioni. Il connettore Snowflake di Athena può combinare queste espressioni e inviarle direttamente a Snowflake per migliorare le funzionalità e ridurre la quantità di dati scansionati.
I seguenti operatori del connettore Athena Snowflake supportano il pushdown dei predicati:
+ **Booleano: **AND, OR, NOT
+ **Uguaglianza: **EQUAL, NOT\_EQUAL, LESS\_THAN, LESS\_THAN\_OR\_EQUAL, GREATER\_THAN, GREATER\_THAN\_OR\_EQUAL, IS\_DISTINCT\_FROM, NULL\_IF, IS\_NULL
+ **Aritmetica: **ADD, SUBTRACT, MULTIPLY, DIVIDE, MODULUS, NEGATE
+ **Altro: **LIKE\_PATTERN, IN
### Esempio di pushdown combinato
Per le funzionalità di esecuzione di query avanzate, combina i tipi di pushdown, come nell'esempio seguente:
```
SELECT *
FROM my_table
WHERE col_a > 10
AND ((col_a + col_b) > (col_c % col_d))
AND (col_e IN ('val1', 'val2', 'val3') OR col_f LIKE '%pattern%')
LIMIT 10;
```
## Query passthrough
[Il connettore Snowflake supporta le query passthrough.](federated-query-passthrough.md) Le query passthrough utilizzano una funzione di tabella per inviare l’intera query all’origine dati per l’esecuzione.
Per utilizzare le query passthrough con Snowflake, puoi utilizzare la seguente sintassi:
```
SELECT * FROM TABLE(
system.query(
query => '{{query string}}'
))
```
La seguente query di esempio invia una query a un'origine dati in Snowflake. La query seleziona tutte le colonne della tabella `customer`, limitando i risultati a 10.
```
SELECT * FROM TABLE(
system.query(
query => 'SELECT * FROM customer LIMIT 10'
))
```
## Informazioni sulla licenza
Utilizzando questo connettore, l'utente riconosce l'inclusione di componenti di terze parti, un elenco dei quali è disponibile nel file [pom.xml](https://github.com/awslabs/aws-athena-query-federation/blob/master/athena-snowflake/pom.xml) relativo a questo connettore, e accetta i termini delle rispettive licenze di terze parti fornite nel file [LICENSE.txt](https://github.com/awslabs/aws-athena-query-federation/blob/master/athena-snowflake/LICENSE.txt) su .com. GitHub
## Risorse aggiuntive
Per le informazioni sulla versione più recente del driver JDBC, consulta il file [pom.xml per il connettore](https://github.com/awslabs/aws-athena-query-federation/blob/master/athena-snowflake/pom.xml) Snowflake su .com. GitHub
Per ulteriori informazioni su questo connettore, visitate [il sito corrispondente](https://github.com/awslabs/aws-athena-query-federation/tree/master/athena-snowflake) su .com. GitHub