Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
# Konektor Kepingan Salju Amazon Athena
Konektor Amazon Athena untuk [Snowflake memungkinkan Amazon](https://www.snowflake.com/) Athena menjalankan kueri SQL pada data yang disimpan dalam database SQL Snowflake atau instans RDS menggunakan JDBC.
Konektor ini dapat didaftarkan dengan Glue Data Catalog sebagai katalog federasi. Ini mendukung kontrol akses data yang didefinisikan dalam Lake Formation di katalog, database, tabel, kolom, baris, dan tingkat tag. Konektor ini menggunakan Glue Connections untuk memusatkan properti konfigurasi di Glue.
## Prasyarat
Menerapkan konektor ke Anda Akun AWS menggunakan konsol Athena atau operasi API`CreateDataCatalog`. Untuk informasi selengkapnya, lihat [Buat koneksi sumber data](connect-to-a-data-source.md).
## Batasan
+ Menulis operasi DDL tidak didukung.
+ Dalam pengaturan multiplexer, bucket tumpahan dan awalan dibagikan di semua instance database.
+ Batas Lambda yang relevan. Untuk informasi selengkapnya, lihat [Kuota Lambda](https://docs.aws.amazon.com/lambda/latest/dg/gettingstarted-limits.html) dalam *Panduan Pengembang AWS Lambda *.
+ Hanya konektor federasi katalog data Athena yang mendukung pengaturan multiplexer.
+ Saat ini, tampilan Snowflake dengan single split didukung.
+ Di Snowflake, nama objek peka huruf besar/kecil. Athena menerima kasus campuran dalam kueri DDL dan DHTML, tetapi secara default [menurunkan nama objek saat mengeksekusi](https://docs.aws.amazon.com/athena/latest/ug/tables-databases-columns-names.html#table-names-and-table-column-names-in-ate-must-be-lowercase) kueri. Konektor Snowflake hanya mendukung huruf kecil saat Glue Catalog/Lake Formation digunakan. Ketika Katalog Athena digunakan, pelanggan dapat mengontrol perilaku casing menggunakan variabel lingkungan `casing_mode` Lambda yang nilainya mungkin tercantum di [Parameter](#connectors-snowflake-parameters) bagian (misalnya,). `key=casing_mode, value = CASE_INSENSITIVE_SEARCH`
## Istilah
Istilah-istilah berikut berhubungan dengan konektor Snowflake.
+ **Instans database** — Instance apa pun dari database yang digunakan di tempat, di Amazon EC2, atau di Amazon RDS.
+ **Handler** - Handler Lambda yang mengakses instance database Anda. Handler bisa untuk metadata atau untuk catatan data.
+ **Metadata handler** — Penangan Lambda yang mengambil metadata dari instance database Anda.
+ **Record handler** - Handler Lambda yang mengambil catatan data dari instance database Anda.
+ **Composite handler** — Handler Lambda yang mengambil data metadata dan data dari instance database Anda.
+ **Properti atau parameter** - Properti database yang digunakan oleh penangan untuk mengekstrak informasi database. Anda mengonfigurasi properti ini sebagai variabel lingkungan Lambda.
+ **Connection String** — Sebuah string teks yang digunakan untuk membuat koneksi ke instance database.
+ **Katalog** —AWS Glue Non-katalog yang terdaftar di Athena yang merupakan awalan yang diperlukan untuk properti. `connection_string`
+ **Multiplexing handler** - Handler Lambda yang dapat menerima dan menggunakan beberapa koneksi database.
## Parameter
Gunakan parameter di bagian ini untuk mengkonfigurasi konektor Snowflake.
### AWS Glue Data Catalog konektor federasi
Kami menyarankan Anda mengkonfigurasi konektor Snowflake dengan menggunakan objek koneksi Glue. Untuk melakukan ini, atur variabel `glue_connection` lingkungan dari konektor Snowflake Lambda ke nama koneksi Glue yang akan digunakan.
**Properti koneksi lem**
Gunakan perintah berikut untuk mendapatkan skema untuk objek koneksi Glue. Skema ini berisi semua parameter yang dapat Anda gunakan untuk mengontrol koneksi Anda.
```
aws glue describe-connection-type --connection-type SNOWFLAKE
```
**Properti lingkungan Lambda**
Properti lingkungan Lambda berikut hanya berlaku ketika Anda menggunakan konektor dengan fungsi Lambda di akun Anda.
+ **glue\_connection** - Menentukan nama koneksi Glue yang terkait dengan konektor federasi.
+ **casing\_mode** - (Opsional) Menentukan bagaimana menangani casing untuk skema dan nama tabel. `casing_mode`Parameter menggunakan nilai-nilai berikut untuk menentukan perilaku casing:
+ **NONE** - Jangan mengubah kasus skema dan nama tabel yang diberikan (jalankan kueri seperti terhadap Snowflake). Ini adalah nilai default ketika **casing\_mode** tidak ditentukan.
+ **UPPER** - Huruf besar semua skema dan nama tabel yang diberikan dalam kueri sebelum menjalankannya terhadap Snowflake.
+ **LOWER** - Huruf kecil semua skema dan nama tabel yang diberikan dalam kueri sebelum menjalankannya terhadap Snowflake.
+ **CASE\_INSENSITIVE\_SEARCH — Lakukan pencarian** case insensitive terhadap skema dan nama tabel di Snowflake. Misalnya, Anda dapat menggunakan mode ini ketika Anda memiliki kueri seperti `SELECT * FROM EMPLOYEE` dan Snowflake berisi tabel yang disebut. `Employee` Namun, dengan adanya tabrakan nama, seperti memiliki tabel yang dipanggil `EMPLOYEE` dan tabel lain yang disebut `Employee` di Snowflake, kueri akan gagal.
**catatan**
Konektor Snowflake yang dibuat menggunakan koneksi AWS Glue Data Catalog federasi tidak mendukung penggunaan handler multiplexing.
Konektor Snowflake yang dibuat menggunakan koneksi AWS Glue Data Catalog federasi hanya mendukung 2. `ConnectionSchemaVersion`
**Menyimpan kredensil**
Semua konektor yang menggunakan koneksi AWS Glue Data Catalog federasi harus digunakan AWS Secrets Manager untuk menyimpan kredensil. Untuk informasi selengkapnya, lihat [Otentikasi dengan Snowflake](connectors-snowflake-authentication.md).
### Konektor federasi katalog data Athena
**catatan**
Konektor sumber data Athena dibuat pada 3 Desember 2024 dan kemudian menggunakan koneksi. AWS Glue
Nama parameter dan definisi yang tercantum di bawah ini adalah untuk konektor sumber data Athena yang dibuat tanpa koneksi Glue terkait. Gunakan parameter berikut hanya jika Anda [menggunakan versi sebelumnya dari konektor sumber data Athena secara manual](connect-data-source-serverless-app-repo.md) atau saat `glue_connection` properti lingkungan tidak ditentukan.
**Properti lingkungan Lambda**
+ **default** - String koneksi JDBC yang digunakan untuk terhubung ke instance database Snowflake. Sebagai contoh, `snowflake://${jdbc_connection_string}`.
+ **catalog\_connection\_string** - Digunakan oleh handler Multiplexing (tidak didukung saat menggunakan sambungan lem). Sebuah string koneksi instance database. Awalan variabel lingkungan dengan nama katalog yang digunakan di Athena. Misalnya, jika katalog yang terdaftar di Athena adalah mysnowflakecatalog, maka nama variabel lingkungan adalah mysnowflakecatalog\_connection\_string.
+ **casing\_mode** - (Opsional) Menentukan bagaimana menangani casing untuk skema dan nama tabel. `casing_mode`Parameter menggunakan nilai-nilai berikut untuk menentukan perilaku casing:
+ **NONE** - Jangan mengubah kasus skema dan nama tabel yang diberikan (jalankan kueri seperti terhadap Snowflake). Ini adalah nilai default ketika **casing\_mode** tidak ditentukan.
+ **UPPER** - Huruf besar semua skema dan nama tabel yang diberikan dalam kueri sebelum menjalankannya terhadap Snowflake.
+ **LOWER** - Huruf kecil semua skema dan nama tabel yang diberikan dalam kueri sebelum menjalankannya terhadap Snowflake.
+ **CASE\_INSENSITIVE\_SEARCH — Lakukan pencarian** case insensitive terhadap skema dan nama tabel di Snowflake. Misalnya, Anda dapat menggunakan mode ini ketika Anda memiliki kueri seperti `SELECT * FROM EMPLOYEE` dan Snowflake berisi tabel yang disebut. `Employee` Namun, dengan adanya tabrakan nama, seperti memiliki tabel yang dipanggil `EMPLOYEE` dan tabel lain yang disebut `Employee` di Snowflake, kueri akan gagal.
+ **spill\_bucket** - Menentukan bucket Amazon S3 untuk data yang melebihi batas fungsi Lambda.
+ **spill\_prefix** — (Opsional) Default ke subfolder dalam nama yang ditentukan. `spill_bucket` `athena-federation-spill` Kami menyarankan Anda mengonfigurasi [siklus hidup penyimpanan](https://docs.aws.amazon.com/AmazonS3/latest/userguide/object-lifecycle-mgmt.html) Amazon S3 di lokasi ini untuk menghapus tumpahan yang lebih lama dari jumlah hari atau jam yang telah ditentukan sebelumnya.
+ **spill\_put\_request\_headers** — (Opsional) Peta header permintaan dan nilai yang disandikan JSON untuk permintaan Amazon S3 yang digunakan untuk menumpahkan (misalnya,). `putObject` `{"x-amz-server-side-encryption" : "AES256"}` Untuk kemungkinan header lainnya, lihat [PutObject](https://docs.aws.amazon.com/AmazonS3/latest/API/API_PutObject.html)di *Referensi API Amazon Simple Storage Service*.
+ **kms\_key\_id** — (Opsional) Secara default, data apa pun yang tumpah ke Amazon S3 dienkripsi menggunakan mode enkripsi yang diautentikasi AES-GCM dan kunci yang dihasilkan secara acak. Agar fungsi Lambda Anda menggunakan kunci enkripsi yang lebih kuat yang dihasilkan oleh KMS seperti`a7e63k4b-8loc-40db-a2a1-4d0en2cd8331`, Anda dapat menentukan ID kunci KMS.
+ **disable\_spill\_encryption** — (Opsional) Ketika diatur ke, menonaktifkan enkripsi tumpahan. `True` Defaultnya `False` sehingga data yang tumpah ke S3 dienkripsi menggunakan AES-GCM — baik menggunakan kunci yang dihasilkan secara acak atau KMS untuk menghasilkan kunci. [Menonaktifkan enkripsi tumpahan dapat meningkatkan kinerja, terutama jika lokasi tumpahan Anda menggunakan enkripsi sisi server.](https://docs.aws.amazon.com/AmazonS3/latest/userguide/serv-side-encryption.html)
#### String koneksi
Gunakan string koneksi JDBC dalam format berikut untuk terhubung ke instance database.
```
snowflake://${{{jdbc_connection_string}}}
```
#### Menggunakan handler multiplexing
Anda dapat menggunakan multiplexer untuk terhubung ke beberapa instance database dengan satu fungsi Lambda. Permintaan dirutekan dengan nama katalog. Gunakan kelas berikut di Lambda.
****
| Handler | Kelas |
| --- | --- |
| Handler komposit | SnowflakeMuxCompositeHandler |
| Penangan metadata | SnowflakeMuxMetadataHandler |
| Rekam handler | SnowflakeMuxRecordHandler |
##### Parameter handler multiplexing
****
| Parameter | Deskripsi |
| --- | --- |
| ${{catalog}}\_connection\_string | Wajib. Sebuah string koneksi instance database. Awalan variabel lingkungan dengan nama katalog yang digunakan di Athena. Misalnya, jika katalog terdaftar di Athena adalahmysnowflakecatalog, maka nama variabel lingkungan adalah. mysnowflakecatalog\_connection\_string |
| default | Wajib. String koneksi default. String ini digunakan saat katalognya lambda:${ {{AWS\_LAMBDA\_FUNCTION\_NAME}}}. |
Contoh properti berikut adalah untuk fungsi Snowflake MUX Lambda yang mendukung dua instance database`snowflake1`: (default), dan. `snowflake2`
****
| Properti | Nilai |
| --- | --- |
| 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 |
##### Memberikan kredensi
Untuk memberikan nama pengguna dan kata sandi untuk database Anda dalam string koneksi JDBC Anda, Anda dapat menggunakan properti string koneksi atau. AWS Secrets Manager
+ **Connection String** - Nama pengguna dan kata sandi dapat ditentukan sebagai properti dalam string koneksi JDBC.
**penting**
Sebagai praktik keamanan terbaik, jangan gunakan kredensi hardcode dalam variabel lingkungan atau string koneksi Anda. *Untuk informasi tentang memindahkan rahasia hardcode Anda AWS Secrets Manager, lihat [Memindahkan rahasia hardcode ke AWS Secrets Manager dalam Panduan](https://docs.aws.amazon.com/secretsmanager/latest/userguide/hardcoded.html) Pengguna.AWS Secrets Manager *
+ **AWS Secrets Manager**[— Untuk menggunakan fitur Query Federasi Athena dengan, VPC AWS Secrets Manager yang terhubung ke fungsi Lambda Anda harus memiliki [akses internet atau](https://aws.amazon.com/premiumsupport/knowledge-center/internet-access-lambda-function/) titik akhir VPC untuk terhubung ke Secrets Manager.](https://docs.aws.amazon.com/secretsmanager/latest/userguide/vpc-endpoint-overview.html)
Anda dapat memasukkan nama rahasia ke AWS Secrets Manager dalam string koneksi JDBC Anda. Konektor menggantikan nama rahasia dengan `password` nilai `username` dan dari Secrets Manager.
Untuk instans database Amazon RDS, dukungan ini terintegrasi erat. Jika Anda menggunakan Amazon RDS, kami sangat menyarankan penggunaan AWS Secrets Manager dan rotasi kredenal. Jika database Anda tidak menggunakan Amazon RDS, simpan kredensialnya sebagai JSON dalam format berikut:
```
{"username": "${username}", "password": "${password}"}
```
**Contoh string koneksi dengan nama rahasia**
String berikut memiliki nama rahasia`${Test/RDS/Snowflake1}`.
```
snowflake://jdbc:snowflake://snowflake1.host:port/?warehouse=warehousename&db=db1&schema=schema1${Test/RDS/Snowflake1}&...
```
Konektor menggunakan nama rahasia untuk mengambil rahasia dan memberikan nama pengguna dan kata sandi, seperti pada contoh berikut.
```
snowflake://jdbc:snowflake://snowflake1.host:port/warehouse=warehousename&db=db1&schema=schema1&user=sample2&password=sample2&...
```
Saat ini, Snowflake mengenali properti `user` dan `password` JDBC. Ini juga menerima nama pengguna dan kata sandi dalam format {{username}} `/` {{password}} tanpa kunci `user` atau`password`.
#### Menggunakan handler koneksi tunggal
Anda dapat menggunakan metadata koneksi tunggal berikut dan penangan rekaman untuk terhubung ke satu instance Snowflake.
****
| Jenis handler | Kelas |
| --- | --- |
| Handler komposit | SnowflakeCompositeHandler |
| Penangan metadata | SnowflakeMetadataHandler |
| Rekam handler | SnowflakeRecordHandler |
##### Parameter handler koneksi tunggal
****
| Parameter | Deskripsi |
| --- | --- |
| default | Wajib. String koneksi default. |
Penangan koneksi tunggal mendukung satu instance database dan harus menyediakan parameter string `default` koneksi. Semua string koneksi lainnya diabaikan.
Properti contoh berikut adalah untuk instance Snowflake tunggal yang didukung oleh fungsi Lambda.
****
| Properti | Nilai |
| --- | --- |
| default | snowflake://jdbc:snowflake://snowflake1.host:port/?secret=Test/RDS/Snowflake1 |
#### Parameter tumpahan
Lambda SDK dapat menumpahkan data ke Amazon S3. Semua instance database yang diakses oleh fungsi Lambda yang sama tumpah ke lokasi yang sama.
****
| Parameter | Deskripsi |
| --- | --- |
| spill\_bucket | Wajib. Nama ember tumpahan. |
| spill\_prefix | Wajib. Tumpahkan key prefix bucket. |
| spill\_put\_request\_headers | (Opsional) Peta header permintaan dan nilai yang disandikan JSON untuk permintaan Amazon S3 yang digunakan untuk menumpahkan (misalnya,). putObject {"x-amz-server-side-encryption" : "AES256"} Untuk kemungkinan header lainnya, lihat [PutObject](https://docs.aws.amazon.com/AmazonS3/latest/API/API_PutObject.html)di Referensi API Amazon Simple Storage Service. |
## Dukungan tipe data
Tabel berikut menunjukkan tipe data yang sesuai untuk JDBC dan Apache Arrow.
****
| JDBC | Panah |
| --- | --- |
| Boolean | Bit |
| Bilangan Bulat | Mungil |
| Pendek | berkulit kecil |
| Bilangan Bulat | Int |
| Panjang | Bigint |
| float | Mengapung4 |
| Ganda | Mengapung8 |
| Date | DateDay |
| Stempel waktu | DateMilli |
| String | Varchar |
| Byte | Varbiner |
| BigDecimal | Decimal |
| ARRAY | Daftar |
## Konversi jenis data
Selain konversi JDBC ke Arrow, konektor melakukan konversi tertentu lainnya untuk membuat sumber Snowflake dan tipe data Athena kompatibel. Konversi ini membantu memastikan bahwa kueri berhasil dieksekusi. Tabel berikut menunjukkan konversi ini.
****
| Tipe data sumber (Snowflake) | Tipe data yang dikonversi (Athena) |
| --- | --- |
| TIMESTAMP | TIMESTAMPMILLI |
| DATE | TIMESTAMPMILLI |
| INTEGER | INT |
| DECIMAL | BIGINT |
| TIMESTAMP\_NTZ | TIMESTAMPMILLI |
Semua tipe data lain yang tidak didukung dikonversi ke`VARCHAR`.
## Partisi dan split
Partisi digunakan untuk menentukan cara menghasilkan split untuk konektor. Athena membangun kolom sintetis tipe `varchar` yang mewakili skema partisi untuk tabel untuk membantu konektor menghasilkan split. Konektor tidak mengubah definisi tabel yang sebenarnya.
Untuk membuat kolom sintetis ini dan partisi, Athena memerlukan kunci primer untuk didefinisikan. Namun, karena Snowflake tidak memberlakukan kendala kunci utama, Anda harus menegakkan keunikan sendiri. Kegagalan untuk melakukannya menyebabkan Athena default ke satu split.
## Performa
Untuk kinerja optimal, gunakan filter dalam kueri bila memungkinkan. Selain itu, kami sangat merekomendasikan partisi asli untuk mengambil kumpulan data besar yang memiliki distribusi partisi seragam. Memilih subset kolom secara signifikan mempercepat runtime kueri dan mengurangi data yang dipindai. Konektor Snowflake tahan terhadap pelambatan karena konkurensi.
Konektor Athena Snowflake melakukan pushdown predikat untuk mengurangi data yang dipindai oleh kueri. `LIMIT`klausa, predikat sederhana, dan ekspresi kompleks didorong ke konektor untuk mengurangi jumlah data yang dipindai dan mengurangi waktu eksekusi kueri.
### Klausul LIMIT
`LIMIT N`Pernyataan mengurangi data yang dipindai oleh kueri. Dengan `LIMIT N` pushdown, konektor hanya mengembalikan `N` baris ke Athena.
### Predikat
Predikat adalah ekspresi dalam `WHERE` klausa kueri SQL yang mengevaluasi nilai Boolean dan menyaring baris berdasarkan beberapa kondisi. Konektor Athena Snowflake dapat menggabungkan ekspresi ini dan mendorongnya langsung ke Snowflake untuk meningkatkan fungsionalitas dan untuk mengurangi jumlah data yang dipindai.
Operator konektor Athena Snowflake berikut mendukung pushdown predikat:
+ **Boolean:** DAN, ATAU, TIDAK
+ **KESETARAAN: SAMA, NOT\_EQUAL**, LESS\_THAN, LESS\_THAN\_OR\_EQUAL, GREATER\_THAN, GREATER\_THAN\_OR\_EQUAL, IS\_DISTINCT\_FROM, NULL\_IF, IS\_NULL
+ **Aritmatika:** TAMBAHKAN, KURANGI, KALIKAN, BAGI, MODULUS, MENIADAKAN
+ **Lainnya:** LIKE\_PATTERN, IN
### Contoh pushdown gabungan
Untuk kemampuan kueri yang ditingkatkan, gabungkan jenis pushdown, seperti pada contoh berikut:
```
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;
```
## Kueri passthrough
Konektor Snowflake mendukung kueri [passthrough](federated-query-passthrough.md). Kueri passthrough menggunakan fungsi tabel untuk mendorong kueri lengkap Anda ke sumber data untuk dieksekusi.
Untuk menggunakan kueri passthrough dengan Snowflake, Anda dapat menggunakan sintaks berikut:
```
SELECT * FROM TABLE(
system.query(
query => '{{query string}}'
))
```
Contoh query berikut mendorong ke bawah query ke sumber data di Snowflake. Kueri memilih semua kolom dalam `customer` tabel, membatasi hasilnya menjadi 10.
```
SELECT * FROM TABLE(
system.query(
query => 'SELECT * FROM customer LIMIT 10'
))
```
## Informasi lisensi
Dengan menggunakan konektor ini, Anda mengakui penyertaan komponen pihak ketiga, daftar yang dapat ditemukan dalam file [pom.xml](https://github.com/awslabs/aws-athena-query-federation/blob/master/athena-snowflake/pom.xml) untuk konektor ini, dan menyetujui persyaratan dalam masing-masing lisensi pihak ketiga yang disediakan dalam file [LICENSE.txt](https://github.com/awslabs/aws-athena-query-federation/blob/master/athena-snowflake/LICENSE.txt) di .com. GitHub
## Sumber daya tambahan
Untuk informasi versi driver JDBC terbaru, lihat file [pom.xml](https://github.com/awslabs/aws-athena-query-federation/blob/master/athena-snowflake/pom.xml) untuk konektor Snowflake di.com. GitHub
Untuk informasi tambahan tentang konektor ini, kunjungi [situs terkait](https://github.com/awslabs/aws-athena-query-federation/tree/master/athena-snowflake) GitHub di.com.