Skip to main content
The container and prefix to read from are set through the container and prefix properties. The DLC ensures that only files within that source can be loaded.
To use this source, a BlobServiceClient bean must be defined. A default one can be used by enabling dlc.create-default-cloud-client.azure.

​
Configuration properties

Properties for an Azure CSV Source are defined by name in the dlc.csv.azure.sources namespace, and are picked up as configurations for the DLC.
KeyRequiredTypeDescription
containerYStringThe container of the directory.
prefixYStringThe directory. Can include Scope Parameters.
Example #{SCOPE_PARAM}
source-propertiesCsvSourceConfigurationPropertiesCSV Source Configuration
cloud-fetching-configCloudFetchingConfigurationPropertiesCloud Fetching Config
topics-to-includeSet<String>Topics to include. See source to topic matching.
topics-to-excludeSet<String>Topics to exclude. See source to topic matching.
accepts-topic-overridesBooleanWhether this source is allowed to accept Topic Overrides in the Load Request.

​
YAML example

dlc:
  csv:
    azure:
      sources:
        azureCsvSource:
          container: container
          prefix: dataDir

​
Java configuration

AzureCsvSourceDescription Spring Beans are picked up as configurations for the DLC.
ParameterRequiredTypeDescription
nameYStringName of the source.
containerYStringThe container of the directory.
prefixYStringThe directory. Can include Scope Parameters.
Example #{SCOPE_PARAM}
sourceConfigurationCsvSourceConfigurationCSV Source Configuration
cloudFetchingConfigCloudFetchingConfigCloud Fetching Config
topicsToIncludeSet<String>Topics to include. See source to topic matching.
topicsToExcludeSet<String>Topics to exclude. See source to topic matching.
acceptsTopicOverridesBooleanWhether this source is allowed to accept Topic Overrides in the Load Request.

​
Java example

@Bean
AzureCsvSourceDescription source() {
    return AzureCsvSourceDescription.builder(
                    "azureCsvSource",
                    "container",
                    "dataDir"
            )
            .build();
}