(path, decryption_config,
kms_connection_config, crypto_factory,
internal_key_material=True)
| 190 | |
| 191 | |
| 192 | def read_encrypted_parquet(path, decryption_config, |
| 193 | kms_connection_config, crypto_factory, |
| 194 | internal_key_material=True): |
| 195 | if internal_key_material: |
| 196 | file_decryption_properties = crypto_factory.file_decryption_properties( |
| 197 | kms_connection_config, decryption_config) |
| 198 | else: |
| 199 | file_decryption_properties = crypto_factory.file_decryption_properties( |
| 200 | kms_connection_config, decryption_config, path) |
| 201 | |
| 202 | assert file_decryption_properties is not None |
| 203 | meta = pq.read_metadata( |
| 204 | path, decryption_properties=file_decryption_properties) |
| 205 | assert meta.num_columns == 3 |
| 206 | schema = pq.read_schema( |
| 207 | path, decryption_properties=file_decryption_properties) |
| 208 | assert len(schema.names) == 3 |
| 209 | |
| 210 | result = pq.ParquetFile( |
| 211 | path, decryption_properties=file_decryption_properties) |
| 212 | return result.read(use_threads=True) |
| 213 | |
| 214 | |
| 215 | def test_encrypted_parquet_write_read_wrong_key(tempdir, data_table): |
no test coverage detected