feat(gooddata-sdk): add CSV upload support for GDSTORAGE data sources

Add five new methods to CatalogDataSourceService:

- staging_upload — upload a CSV to the staging area
- analyze_csv — detect columns, types, and parse config
- import_csv — import a staged CSV into a GDSTORAGE data source
- delete_csv_files — remove files from a data source
- upload_csv — end-to-end convenience wrapper

Also add CatalogDataSourceGdStorage entity model with _NoCredentials
support (GDSTORAGE sources require no authentication), export the new
symbol, add the `result` spec to the Makefile download target, and
add documentation pages for all new methods.

jira: TRIVIAL
risk: low

Author: hkad98

Makefile

@@ -66,6 +66,7 @@ download:
 	$(call download_client,scan)
 	$(call download_client,"export")
 	$(call download_client,automation)
+	$(call download_client,result)
 
 .PHONY: type-check
 type-check:

docs/content/en/latest/data/data-source/_index.md

@@ -37,6 +37,14 @@ See [Connect Data](https://www.gooddata.com/docs/cloud/connect-data/) to learn h
 * [scan_schemata](./scan_schemata/)
 * [scan_sql](./scan_sql/)
 
+### CSV Upload Methods
+
+* [staging_upload](./staging_upload/)
+* [analyze_csv](./analyze_csv/)
+* [import_csv](./import_csv/)
+* [delete_csv_files](./delete_csv_files/)
+* [upload_csv](./upload_csv/)
+
 
 ## Example
 

docs/content/en/latest/data/data-source/analyze_csv.md

@@ -0,0 +1,37 @@
+---
+title: "analyze_csv"
+linkTitle: "analyze_csv"
+weight: 191
+superheading: "catalog_data_source."
+---
+
+
+
+``analyze_csv(location: str)``
+
+Analyzes an uploaded CSV file in the staging area. Returns column metadata, detected types, preview data, and a config object that can be passed to import_csv.
+
+{{% parameters-block  title="Parameters"%}}
+
+{{< parameter p_name="location" p_type="string" >}}
+Location string returned by staging_upload.
+{{< /parameter >}}
+
+{{% /parameters-block %}}
+
+{{% parameters-block title="Returns"%}}
+
+{{< parameter p_type="AnalyzeCsvResponse" >}}
+Analysis result with columns, preview data, and config.
+{{< /parameter >}}
+
+{{% /parameters-block %}}
+
+## Example
+
+```python
+# Analyze a previously uploaded CSV file
+analysis = sdk.catalog_data_source.analyze_csv(location="staging/some-location")
+for col in analysis["columns"]:
+    print(f"{col['name']}: {col['type']}")
+```

docs/content/en/latest/data/data-source/delete_csv_files.md

@@ -0,0 +1,37 @@
+---
+title: "delete_csv_files"
+linkTitle: "delete_csv_files"
+weight: 193
+superheading: "catalog_data_source."
+---
+
+
+
+``delete_csv_files(data_source_id: str, file_names: list[str])``
+
+Deletes files from a GDSTORAGE data source.
+
+{{% parameters-block  title="Parameters"%}}
+
+{{< parameter p_name="data_source_id" p_type="string" >}}
+Data source identification string.
+{{< /parameter >}}
+
+{{< parameter p_name="file_names" p_type="list[string]" >}}
+List of file names to delete.
+{{< /parameter >}}
+
+{{% /parameters-block %}}
+
+{{% parameters-block title="Returns" None="yes"%}}
+{{% /parameters-block %}}
+
+## Example
+
+```python
+# Delete specific files from a GDSTORAGE data source
+sdk.catalog_data_source.delete_csv_files(
+    data_source_id="my-gdstorage-ds",
+    file_names=["my_table.csv"],
+)
+```

docs/content/en/latest/data/data-source/import_csv.md

@@ -0,0 +1,49 @@
+---
+title: "import_csv"
+linkTitle: "import_csv"
+weight: 192
+superheading: "catalog_data_source."
+---
+
+
+
+``import_csv(data_source_id: str, table_name: str, location: str, config: Optional[dict] = None)``
+
+Imports a CSV file from the staging area into a GDSTORAGE data source.
+
+{{% parameters-block  title="Parameters"%}}
+
+{{< parameter p_name="data_source_id" p_type="string" >}}
+Data source identification string.
+{{< /parameter >}}
+
+{{< parameter p_name="table_name" p_type="string" >}}
+Name for the table to create or replace.
+{{< /parameter >}}
+
+{{< parameter p_name="location" p_type="string" >}}
+Location string returned by staging_upload.
+{{< /parameter >}}
+
+{{< parameter p_name="config" p_type="Optional[dict]" >}}
+Source config dict, typically from analyze_csv response. Optional.
+{{< /parameter >}}
+
+{{% /parameters-block %}}
+
+{{% parameters-block title="Returns" None="yes"%}}
+{{% /parameters-block %}}
+
+## Example
+
+```python
+# Import a CSV into a GDSTORAGE data source using config from analysis
+analysis = sdk.catalog_data_source.analyze_csv(location=location)
+config = analysis.to_dict().get("config")
+sdk.catalog_data_source.import_csv(
+    data_source_id="my-gdstorage-ds",
+    table_name="my_table",
+    location=location,
+    config=config,
+)
+```

docs/content/en/latest/data/data-source/staging_upload.md

@@ -0,0 +1,37 @@
+---
+title: "staging_upload"
+linkTitle: "staging_upload"
+weight: 190
+superheading: "catalog_data_source."
+---
+
+
+
+``staging_upload(csv_file: Path)``
+
+Uploads a CSV file to the staging area and returns a location string that can be used in subsequent calls to analyze_csv and import_csv.
+
+{{% parameters-block  title="Parameters"%}}
+
+{{< parameter p_name="csv_file" p_type="Path" >}}
+Path to the CSV file to upload.
+{{< /parameter >}}
+
+{{% /parameters-block %}}
+
+{{% parameters-block title="Returns"%}}
+
+{{< parameter p_type="string" >}}
+Location string referencing the uploaded file in staging.
+{{< /parameter >}}
+
+{{% /parameters-block %}}
+
+## Example
+
+```python
+from pathlib import Path
+
+# Upload a CSV file to staging
+location = sdk.catalog_data_source.staging_upload(csv_file=Path("data.csv"))
+```

docs/content/en/latest/data/data-source/upload_csv.md

@@ -0,0 +1,44 @@
+---
+title: "upload_csv"
+linkTitle: "upload_csv"
+weight: 194
+superheading: "catalog_data_source."
+---
+
+
+
+``upload_csv(data_source_id: str, csv_file: Path, table_name: str)``
+
+Convenience method that uploads a CSV file and imports it into a GDSTORAGE data source in a single call. Orchestrates the full flow: staging_upload → analyze_csv → import_csv → register_upload_notification.
+
+{{% parameters-block  title="Parameters"%}}
+
+{{< parameter p_name="data_source_id" p_type="string" >}}
+Data source identification string for a GDSTORAGE data source.
+{{< /parameter >}}
+
+{{< parameter p_name="csv_file" p_type="Path" >}}
+Path to the CSV file to upload.
+{{< /parameter >}}
+
+{{< parameter p_name="table_name" p_type="string" >}}
+Name for the table to create or replace in the data source.
+{{< /parameter >}}
+
+{{% /parameters-block %}}
+
+{{% parameters-block title="Returns" None="yes"%}}
+{{% /parameters-block %}}
+
+## Example
+
+```python
+from pathlib import Path
+
+# Upload a CSV file end-to-end in a single call
+sdk.catalog_data_source.upload_csv(
+    data_source_id="my-gdstorage-ds",
+    csv_file=Path("data.csv"),
+    table_name="my_table",
+)
+```

packages/gooddata-sdk/src/gooddata_sdk/__init__.py

@@ -29,6 +29,7 @@
     CatalogDataSource,
     CatalogDataSourceBigQuery,
     CatalogDataSourceDatabricks,
+    CatalogDataSourceGdStorage,
     CatalogDataSourceGreenplum,
     CatalogDataSourceMariaDb,
     CatalogDataSourceMotherDuck,

packages/gooddata-sdk/src/gooddata_sdk/catalog/data_source/entity_model/data_source.py

@@ -296,3 +296,25 @@ class MotherDuckAttributes(DatabaseAttributes):
 class CatalogDataSourceMotherDuck(CatalogDataSource):
     _URL_TMPL: ClassVar[str] = "jdbc:duckdb:md:{db_name}"
     type: str = "MOTHERDUCK"
+
+
+class _NoCredentials(Credentials):
+    """Placeholder credentials for data sources that do not require authentication."""
+
+    def to_api_args(self) -> dict[str, Any]:
+        return {}
+
+    @classmethod
+    def is_part_of_api(cls, entity: dict[str, Any]) -> bool:
+        return True
+
+    @classmethod
+    def from_api(cls, entity: dict[str, Any]) -> _NoCredentials:
+        return cls()
+
+
+@define(kw_only=True, eq=False)
+class CatalogDataSourceGdStorage(CatalogDataSource):
+    type: str = "GDSTORAGE"
+    schema: str = ""
+    credentials: Credentials = field(factory=_NoCredentials, repr=False)

packages/gooddata-sdk/src/gooddata_sdk/catalog/data_source/service.py

@@ -7,6 +7,16 @@
 
 from gooddata_api_client.exceptions import NotFoundException
 
+# CSV upload related imports from generated API client
+from gooddata_api_client.model.analyze_csv_request import AnalyzeCsvRequest
+from gooddata_api_client.model.analyze_csv_request_item import AnalyzeCsvRequestItem
+from gooddata_api_client.model.analyze_csv_response import AnalyzeCsvResponse
+from gooddata_api_client.model.delete_files_request import DeleteFilesRequest
+from gooddata_api_client.model.import_csv_request import ImportCsvRequest
+from gooddata_api_client.model.import_csv_request_table import ImportCsvRequestTable
+from gooddata_api_client.model.import_csv_request_table_source import ImportCsvRequestTableSource
+from gooddata_api_client.model.import_csv_request_table_source_config import ImportCsvRequestTableSourceConfig
+
 from gooddata_sdk.catalog.catalog_service_base import CatalogServiceBase
 from gooddata_sdk.catalog.data_source.action_model.requests.ldm_request import (
     CatalogGenerateLdmRequest,
@@ -504,6 +514,110 @@ def test_data_sources_connection(
                 message.append(f"Test connection for data source id {k} ended with the following error {v}.")
             raise ValueError("\n".join(message))
 
+    # CSV upload methods are listed below
+
+    def staging_upload(self, csv_file: Path) -> str:
+        """Upload a CSV file to the staging area.
+
+        Args:
+            csv_file (Path):
+                Path to the CSV file to upload.
+
+        Returns:
+            str:
+                Location string referencing the uploaded file in staging.
+        """
+        with open(csv_file, "rb") as f:
+            response = self._actions_api.staging_upload(file=f)
+        return response["location"]
+
+    def analyze_csv(self, location: str) -> AnalyzeCsvResponse:
+        """Analyze an uploaded CSV file in the staging area.
+
+        Returns column metadata, detected types, and a config object
+        that can be passed directly to import_csv.
+
+        Args:
+            location (str):
+                Location string returned by staging_upload.
+
+        Returns:
+            AnalyzeCsvResponse:
+                Analysis result with columns, preview data, and config.
+        """
+        request = AnalyzeCsvRequest(analyze_requests=[AnalyzeCsvRequestItem(location=location)])
+        responses = self._actions_api.analyze_csv(request, _check_return_type=False)
+        return responses[0]
+
+    def import_csv(
+        self,
+        data_source_id: str,
+        table_name: str,
+        location: str,
+        config: dict[str, Any] | None = None,
+    ) -> None:
+        """Import a CSV file from staging into a GDSTORAGE data source.
+
+        Args:
+            data_source_id (str):
+                Data source identification string.
+            table_name (str):
+                Name for the table to create or replace.
+            location (str):
+                Location string returned by staging_upload.
+            config (Optional[dict[str, Any]]):
+                Source config dict, typically from analyze_csv response.
+                Passed as ImportCsvRequestTableSourceConfig kwargs.
+
+        Returns:
+            None
+        """
+        source_kwargs: dict[str, Any] = {"location": location}
+        if config:
+            source_kwargs["config"] = ImportCsvRequestTableSourceConfig(**config)
+        source = ImportCsvRequestTableSource(**source_kwargs)
+        table = ImportCsvRequestTable(name=table_name, source=source)
+        request = ImportCsvRequest(tables=[table])
+        self._actions_api.import_csv(data_source_id, request)
+
+    def delete_csv_files(self, data_source_id: str, file_names: list[str]) -> None:
+        """Delete files from a GDSTORAGE data source.
+
+        Args:
+            data_source_id (str):
+                Data source identification string.
+            file_names (list[str]):
+                List of file names to delete.
+
+        Returns:
+            None
+        """
+        request = DeleteFilesRequest(file_names=file_names)
+        self._actions_api.delete_files(data_source_id, request)
+
+    def upload_csv(self, data_source_id: str, csv_file: Path, table_name: str) -> None:
+        """Upload a CSV file and import it into a GDSTORAGE data source.
+
+        Convenience method that orchestrates the full flow:
+        staging_upload → analyze_csv → import_csv → register_upload_notification.
+
+        Args:
+            data_source_id (str):
+                Data source identification string for a GDSTORAGE data source.
+            csv_file (Path):
+                Path to the CSV file to upload.
+            table_name (str):
+                Name for the table to create or replace in the data source.
+
+        Returns:
+            None
+        """
+        location = self.staging_upload(csv_file)
+        analysis = self.analyze_csv(location)
+        config = analysis.to_dict().get("config")
+        self.import_csv(data_source_id, table_name, location, config=config)
+        self.register_upload_notification(data_source_id)
+
     # Help methods are listed below
 
     @staticmethod