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