Use change data capture to stream flat files from a Google Cloud Storage folder to any data sink and transform them on the way.
At startup, the connector extracts data from all (matching) files from the given folder. After this initial sync, it watches the folder for new or updated files and syncs only relevant changes.
Please make sure that you have created a service account in Google Cloud, which is assigned to the primitive IAM role Storage Admin (or the permissions storage.buckets.list, storage.objects.get, and storage.objects.list) on the level of the project.
This source connector supports the following configuration options:
The content of the JSON-based credentials file provided by Google Cloud for the service account.
The name of the GCP project. We try to automatically extract the name of the GCP project from the provided Google Cloud credentials.
The name of the GCS bucket from which we shall extract files.
Regular expression applied to files from the GCS bucket. Only files with a name matching the regular expression will be extracted. Default value: .* (matches all file names).
The format of the extracted files. At the moment, this connector only supports CSV files.
Only available for the file type CSV. The character that delimits different columns (default: ,).
Only available for the file format CSV. Character used for quotes (default: ").
Only available for the file format CSV. Character used for escaping quotes (default: ").
Only available for the file format CSV. String used for separating multiple lines (default: \n).
Only available for the file format CSV. Character used for comments. It must appear at the beginning of a line (default: #).
Only available for the file type CSV. Whether to use the first row of the CSV file for extracting attribute names or not. If this option is set to false, DataCater will generate attribute names based on the index of the attribute, and name them column_1, column_2, etc.
Name of the attribute that uniquely identifies records, similar to a primary key in a database system.
The interval in seconds between the synchronization of the GCS bucket and DataCater (default: 120). When synchronizing, DataCater consumes only those files from the GCS bucket, which have not yet been processed by the pipeline, allowing to implement change data capture to some degree.
DataCater imports all columns of a CSV file as attributes of type string.
DataCater automatically extends the set of attributes with the attribute __datacater_file_name and fills it with the name of the file.