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à.
Il connettore Amazon Athena per Oracle consente ad Amazon Athena di eseguire query SQL sui dati archiviati in Oracle in esecuzione in locale o su Amazon o Amazon RDS. EC2 Puoi anche utilizzare il connettore per eseguire query sui dati Oracle Exadata
Questo connettore non può essere registrato con Glue Data Catalog come catalogo federato. Questo connettore non supporta i controlli di accesso ai dati definiti in Lake Formation a livello di catalogo, database, tabella, colonna, riga e tag. Questo connettore utilizza Glue Connections per centralizzare le proprietà di configurazione in Glue.
Prerequisiti
Implementa il connettore sul tuo Account AWS utilizzando la console Athena o AWS Serverless Application Repository. Per ulteriori informazioni, consulta Creare una connessione a una fonte di dati o Utilizzare il AWS Serverless Application Repository per distribuire un connettore di origine dati.
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 nella Guida per gli sviluppatori di AWS Lambda .
-
Sono supportati solo i database Oracle versione 12.1.0.2.
-
Se il connettore Oracle non utilizza una connessione Glue, i nomi di database, tabelle e colonne verranno convertiti in lettere maiuscole dal connettore.
Se il connettore Oracle utilizza una connessione Glue, i nomi di database, tabelle e colonne non verranno utilizzati per impostazione predefinita in maiuscolo dal connettore. Aggiungi virgolette doppie («) attorno ai nomi degli oggetti per mantenere le maiuscole e minuscole. Per modificare questo comportamento di classificazione dei casi, modifica la
casing_modevariabile di ambiente Lambda by inlowerouppersecondo necessità. -
Quando si utilizza Oracle
NUMBERsenza definire Precisione e Scala, Athena lo considera come.BIGINTPer ottenere le cifre decimali richieste in Athena, specifica nelledefault_scale=<variabili di ambiente Lambda.number of decimal places>
Termini
I seguenti termini si riferiscono al connettore Oracle.
-
Istanza di database: qualsiasi istanza di un database distribuita in locale, 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.
Parametri
Utilizza i parametri di questa sezione per configurare il connettore Oracle.
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 prima del 3 dicembre 2024. Questi possono differire dalle proprietà di AWS Glue connessione corrispondenti. A partire dal 3 dicembre 2024, utilizza i parametri seguenti solo quando distribuisci manualmente una versione precedente di un connettore di origine dati Athena.
Stringa di connessione
Utilizza una stringa di connessione JDBC nel formato seguente per connetterti a un'istanza del database.
oracle://${jdbc_connection_string}
Nota
Se la password contiene caratteri speciali (ad esempio some.password), racchiudi la password tra virgolette doppie quando la passi alla stringa di connessione (ad esempio "some.password"). In caso contrario, è possibile che venga generato come errore URL Oracle specificato non valido.
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 | OracleMuxCompositeHandler |
| Gestore dei metadati | OracleMuxMetadataHandler |
| Gestore dei record | OracleMuxRecordHandler |
Parametri del gestore multiplex
| Parametro | Descrizione |
|---|---|
$ |
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 è myoraclecatalog, il nome della variabile di ambiente è myoraclecatalog_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 Oracle MUX che supporta due istanze del database: oracle1 (il valore predefinito) e oracle2.
| Proprietà | Valore |
|---|---|
default |
oracle://jdbc:oracle:thin:${Test/RDS/Oracle1}@//oracle1.hostname:port/servicename |
oracle_catalog1_connection_string |
oracle://jdbc:oracle:thin:${Test/RDS/Oracle1}@//oracle1.hostname:port/servicename |
oracle_catalog2_connection_string |
oracle://jdbc:oracle:thin:${Test/RDS/Oracle2}@//oracle2.hostname:port/servicename |
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 AWS Secrets Manager.
-
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 AWS Secrets Manager, consulta Move i segreti codificati AWS Secrets Manager nella Guida per l'utente.AWS Secrets Manager
-
AWS Secrets Manager— Per utilizzare la funzionalità Athena Federated Query con, AWS Secrets Manager il VPC collegato alla funzione Lambda deve avere accesso a Internet o
un endpoint VPC per connettersi a Secrets Manager. È possibile inserire il nome di un segreto nella AWS Secrets Manager stringa di connessione JDBC. Il connettore sostituisce il nome del segreto con i valori
usernameepassworddi Secrets Manager.Per le istanze del database Amazon RDS, questo supporto è strettamente integrato. Se usi Amazon RDS, ti consigliamo vivamente di utilizzare AWS Secrets Manager la rotazione delle credenziali. Se il tuo database non utilizza Amazon RDS, archivia le credenziali come JSON nel seguente formato:
{"username": "${username}", "password": "${password}"}
Nota
Se la password contiene caratteri speciali (ad esempio some.password), racchiudi la password tra virgolette doppie quando la memorizzi in Secrets Manager (ad esempio "some.password"). In caso contrario, è possibile che venga generato come errore URL Oracle specificato non valido.
Esempio di stringa di connessione con nome del segreto
La stringa seguente ha il nome del segreto ${Test/RDS/Oracle}.
oracle://jdbc:oracle:thin:${Test/RDS/Oracle}@//hostname:port/servicename Il connettore utilizza il nome del segreto per recuperare i segreti e fornire il nome utente e la password, come nell'esempio seguente.
oracle://jdbc:oracle:thin:username/password@//hostname:port/servicenameAttualmente, il connettore Oracle riconosce le proprietà JDBC UID e PWD.
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 Oracle.
| Tipo di gestore | Classe |
|---|---|
| Gestore composito | OracleCompositeHandler |
| Gestore dei metadati | OracleMetadataHandler |
| Gestore dei record | OracleRecordHandler |
Parametri del gestore a singola connessione
| Parametro | Descrizione |
|---|---|
default |
Obbligatorio. La stringa di connessione predefinita. |
IsFIPSEnabled |
Facoltativo. Imposta su true quando è abilitata la modalità FIPS. Il valore predefinito è false. |
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.
Il connettore supporta connessioni basate su SSL alle istanze Amazon RDS. Il supporto è limitato al protocollo Transport Layer Security (TLS) e all'autenticazione del server da parte del client. L'autenticazione reciproca non è supportata in Amazon RDS. La seconda riga della tabella seguente mostra la sintassi per l'utilizzo di SSL.
La seguente proprietà di esempio si riferisce a una singola istanza Oracle supportata da una funzione Lambda.
| Proprietà | Valore |
|---|---|
default |
oracle://jdbc:oracle:thin:${Test/RDS/Oracle}@//hostname:port/servicename |
oracle://jdbc:oracle:thin:${Test/RDS/Oracle}@(DESCRIPTION=(ADDRESS=(PROTOCOL=TCPS)
(HOST=<HOST_NAME>)(PORT=))(CONNECT_DATA=(SID=))(SECURITY=(SSL_SERVER_CERT_DN=))) |
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 | Descrizione |
|---|---|
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 PutObjectall'API di Amazon Simple Storage Service. |
Involucro
È possibile utilizzare il seguente parametro di involucro per impostare diverse modalità di involucro. È possibile modificare la modalità di rivestimento predefinita nelle variabili di ambiente Lambda per il connettore indipendentemente da una connessione a colla.
-
casing_mode — (Facoltativo) Specifica come gestire il casing per i nomi di schemi e tabelle. Il
casing_modeparametro utilizza i seguenti valori per specificare il comportamento dell'involucro:-
minuscolo: tutti i nomi di schemi e tabelle specificati in minuscolo. Questa è l'impostazione predefinita per i connettori a cui è associata una connessione di collegamento.
-
upper — Tutti i nomi di schemi e tabelle specificati in maiuscolo. Questa è l'impostazione predefinita per i connettori a cui non è associata una connessione di collegamento.
-
case_insensitive_search — Esegue ricerche senza distinzione tra maiuscole e minuscole nei nomi di schemi e tabelle in Oracle. Utilizzate questo valore se la query contiene nomi di schemi o tabelle che non corrispondono all'involucro predefinito del connettore.
-
Supporto dei tipi di dati
Nella tabella seguente vengono illustrati i tipi di dati corrispondenti per JDBC, Oracle e Arrow.
| JDBC | Oracle | Arrow |
|---|---|---|
| Booleano | booleano | Bit |
| Numero intero | N/D | Tiny |
| Breve | smallint | Smallint |
| Numero intero | integer | Int |
| Long | bigint | Bigint |
| float | float4 | Float4 |
| Doppio | float8 | Float8 |
| Data | date | DateDay |
| Timestamp | timestamp | DateMilli |
| Stringa | text | Varchar |
| Byte | bytes | Varbinary |
| BigDecimal | numeric(p,s) | Decimale |
| ARRAY | N/D (vedi nota) | Elenco |
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.
Prestazioni
Oracle supporta le partizioni native. Il connettore Oracle di Athena può recuperare dati da queste partizioni in parallelo. Se desideri interrogare set di dati molto grandi con una distribuzione uniforme delle partizioni, ti consigliamo vivamente il partizionamento nativo. La selezione di un sottoinsieme di colonne velocizza notevolmente il runtime delle query e riduce i dati scansionati. Il connettore Oracle è resiliente alla limitazione della larghezza di banda della rete dovuta alla simultaneità. Tuttavia, i tempi di esecuzione delle query tendono a essere lunghi.
Il connettore Athena Oracle esegue il pushdown del predicato per ridurre la quantità di dati scansionati dalla query. I predicati semplici e le espressioni complesse vengono inviati al connettore per ridurre la quantità di dati scansionati e ridurre il tempo di esecuzione delle query.
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 Oracle di Athena può combinare queste espressioni e inviarle direttamente a Oracle per funzionalità avanzate e per ridurre la quantità di dati scansionati.
I seguenti operatori del connettore Oracle di Athena 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_NULL
-
Aritmetica: ADD, SUBTRACT, MULTIPLY, DIVIDE, 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%');Interrogazioni pass-through
Il connettore Oracle supporta le query passthrough. Le query passthrough utilizzano una funzione di tabella per inviare la query completa alla fonte di dati per l'esecuzione.
Per utilizzare le query passthrough con Oracle, 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 Oracle. La query seleziona tutte le colonne della customer tabella.
SELECT * FROM TABLE(
system.query(
query => 'SELECT * FROM customer'
))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
Risorse aggiuntive
Per le informazioni sulla versione più recente del driver JDBC, consulta il file pom.xml
Per ulteriori informazioni su questo connettore, visita il sito corrispondente su GitHub .com
