pub async fn create_datasource( &self, name: String, location: String, user_name: String, password: String, ) -> Result<CreateDatasourceResponse, KineticaError>
Create a data source
Creates a data source, which contains the location and connection information for a data store that is external to the database.
name- Name of the data source to be created.location- Location of the remote storage in ‘storage_provider_type://[storage_path[:storage_port]]’ format.Supported storage provider types are ‘azure’, ‘gcs’, ‘hdfs’, ‘jdbc’, ‘kafka’, ‘confluent’, and ‘s3’.
user_name- Name of the remote system user; may be an empty string.password- Password for the remote system user; may be an empty string.
pub async fn create_datasource_with_opts( &self, name: String, location: String, user_name: String, password: String, options: CreateDatasourceRequestOptions, ) -> Result<CreateDatasourceResponse, KineticaError>
Create a data source
Creates a data source, which contains the location and connection information for a data store that is external to the database.
name- Name of the data source to be created.location- Location of the remote storage in ‘storage_provider_type://[storage_path[:storage_port]]’ format.Supported storage provider types are ‘azure’, ‘gcs’, ‘hdfs’, ‘jdbc’, ‘kafka’, ‘confluent’, and ‘s3’.
user_name- Name of the remote system user; may be an empty string.password- Password for the remote system user; may be an empty string.options- The optional parameters; any left unset take the server’s defaults.
pub async fn create_datasource_raw( &self, request: &CreateDatasourceRequest, ) -> Result<CreateDatasourceResponse, KineticaError>
Sends a pre-built CreateDatasourceRequest to the /create/datasource endpoint.
pub async fn create_datasource_from_url( &self, url: &str, request: &CreateDatasourceRequest, ) -> Result<CreateDatasourceResponse, KineticaError>
Sends a pre-built CreateDatasourceRequest to a specific worker URL, bypassing HA head-node selection. Used for multi-head access.