in src/main/java/com/epam/digital/data/platform/integration/ceph/service/impl/CephServiceS3Impl.java [196:211]
public List<CephObjectMetadata> getMetadata(String cephBucketName, Set<String> keys) {
log.info("Getting file metadata for keys {} from ceph bucket {}", keys, cephBucketName);
assertBucketExists(cephAmazonS3, cephBucketName);
var existingKeys = execute(
() -> keys.stream().filter(k -> cephAmazonS3.doesObjectExist(cephBucketName, k)).collect(
Collectors.toList()));
if (existingKeys.isEmpty()) {
log.info("Files {} wasn't found in ceph bucket {}", keys, cephBucketName);
return Collections.emptyList();
}
var result = execute(() -> existingKeys.stream()
.map(k -> cephAmazonS3.getObjectMetadata(cephBucketName, k)).collect(Collectors.toList()));
log.info("Files metadata {} was found in ceph bucket {}", existingKeys, cephBucketName);
return toCephObjectMetadataList(result);
}