in connector/src/main/scala/com/microsoft/kusto/spark/utils/KeyVaultUtils.scala [87:104]
private def getStorageParamsFromKeyVaultImpl(
client: SecretClient,
uri: String): TransientStorageCredentials = {
val sasUrl = Try(client.getSecret(SasUrl))
val accountName = Try(client.getSecret(StorageAccountName))
val accountKey = Try(client.getSecret(StorageAccountKey))
val container = Try(client.getSecret(Container))
if (sasUrl.isFailure) {
new TransientStorageCredentials(
if (accountName.isFailure) accountName.get.getValue else "",
if (accountKey.isFailure) accountKey.get.getValue else "",
if (container.isFailure) container.get.getValue else "")
} else {
new TransientStorageCredentials(sasUrl.get.getValue)
}
}