Skip to content

50 integrate append flow api#58

Merged
ravi-databricks merged 7 commits intofeature/v0.0.8from
50-integrate-append-flow-api
Jul 3, 2024
Merged

50 integrate append flow api#58
ravi-databricks merged 7 commits intofeature/v0.0.8from
50-integrate-append-flow-api

Conversation

@ravi-databricks
Copy link
Contributor

Incorporated dlt.append_flow api into dlt-meta.
Introducing config in onboarding file for bronze/silver layer as below


        "bronze_append_flows": [
            {
                "name": "customer_bronze_flow",
                "create_streaming_table": false,
                "source_format": "cloudFiles",
                "source_details": {
                    "source_database": "APP",
                    "source_table": "CUSTOMERS",
                    "source_path_dev": "tests/resources/data/customers_af",
                    "source_schema_path": "tests/resources/schema/customers.ddl"
                },
                "reader_options": {
                    "cloudFiles.format": "json",
                    "cloudFiles.inferColumnTypes": "true",
                    "cloudFiles.rescuedDataColumn": "_rescued_data"
                },
                "once": true
            }
        ]

This way many sources can be added as part of single dlt pipeline which will append to same target table.
In dataflow_pipeline.py added AppendFlowWriter which take this config and calls dlt.append_flow api

1.dlt.append_flow api incorporation in bronze/silver layer
2.dlt.cdc_apply_changes additional api attributes incorporation
@ravi-databricks ravi-databricks added the enhancement New feature or request label Jul 2, 2024
@ravi-databricks ravi-databricks added this to the v0.0.8 milestone Jul 2, 2024
@ravi-databricks ravi-databricks self-assigned this Jul 2, 2024
Copy link

@neil90-db neil90-db left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looks good, LGTM. Supporting Append Flows is great addition!

Copy link
Contributor

@howardwu-db howardwu-db left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@ravi-databricks ravi-databricks merged commit 5c056ad into feature/v0.0.8 Jul 3, 2024
@ravi-databricks ravi-databricks mentioned this pull request Jul 29, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

enhancement New feature or request

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants