diff --git a/docs/website/docs/reference/explainers/how-dlt-works.md b/docs/website/docs/reference/explainers/how-dlt-works.md index fa73babd03..570bc8cdbe 100644 --- a/docs/website/docs/reference/explainers/how-dlt-works.md +++ b/docs/website/docs/reference/explainers/how-dlt-works.md @@ -6,33 +6,71 @@ keywords: [architecture, extract, normalize, load] # How `dlt` works -`dlt` automatically turns JSON returned by any [source](../../general-usage/glossary.md#source) -(e.g., an API) into a live dataset stored in the -[destination](../../general-usage/glossary.md#destination) of your choice (e.g., Google BigQuery). It -does this by first [extracting](how-dlt-works.md#extract) the JSON data, then -[normalizing](how-dlt-works.md#normalize) it to a schema, and finally [loading](how-dlt-works#load) -it to the location where you will store it. +In a nutshell, `dlt` automatically turns data from a number of available [sources](../../dlt-ecosystem/verified-sources) (e.g., an API, a PostgreSQL database, or Python data structures) into a live dataset stored in a [destination](../../dlt-ecosystem/destinations) of your choice (e.g., Google BigQuery, a Deltalake on Azure, or by pushing the data back via reverse ETL). You can easily implement your own sources, as long as you yield data in a way that is compatible with `dlt`, such as JSON objects, Python lists and dictionaries, pandas dataframes, and arrow tables. `dlt` will be able to automatically compute the schema and move the data to your destination. -![architecture-diagram](/img/architecture-diagram.png) +![architecture-diagram](/img/dlt-onepager.png) -## Extract +## A concrete example -The Python script requests data from an API or a similar -[source](../../general-usage/glossary.md#source). Once this data is received, the script parses the -JSON and provides it to `dlt` as input, which then normalizes that data. +The main building block of `dlt` is the [pipeline](../../general-usage/glossary.md#pipeline), which orchestrates the loading of data from your source into your destination in three discrete steps when you call its `run` method. Consider this intentionally short example: -## Normalize +```py +import dlt -The configurable normalization engine in `dlt` recursively unpacks this nested structure into -relational tables (i.e., inferring data types, linking tables to create nested relationships, -etc.), making it ready to be loaded. This creates a -[schema](../../general-usage/glossary.md#schema), which will automatically evolve to accommodate any future -source data changes (e.g., new fields or tables). +pipeline = dlt.pipeline(pipeline_name="my_pipeline", destination="duckdb") +pipeline.run( + [ + {"id": 1}, + {"id": 2}, + {"id": 3, "nested": [{"id": 1}, {"id": 2}]}, + ], + table_name="items", +) +``` -## Load +This is what happens when the `run` method is executed: -The data is then loaded into your chosen [destination](../../general-usage/glossary.md#destination). -`dlt` uses configurable, idempotent, atomic loads that ensure data safely ends up there. For -example, you don't need to worry about the size of the data you are loading, and if the process is -interrupted, it is safe to retry without creating errors. +1. [Extract](how-dlt-works.md#extract) - Fully extracts the data from your source to your hard drive. In the example above, an implicit source with one resource with 3 items is created and extracted. +2. [Normalize](how-dlt-works.md#normalize) - Inspects and normalizes your data and computes a schema compatible with your destination. For the example above, the normalizer will detect one column `id` of type `int` in one table named `items`, it will furthermore detect a nested list in table items and unnest it into a child table named `items__nested`. +3. [Load](how-dlt-works#load) - Runs schema migrations if necessary on your destination and loads your data into the destination. For the example above, a new dataset on a local duckdb database is created that contains the two tables discovered in the previous steps. +## The three phases + +### Extract + +Extract can be run individually with the `extract` command on the pipeline: + +```py +pipeline.extract(data) +``` + +During the extract phase, `dlt` fully extracts the data from your [sources](../../dlt-ecosystem/verified-sources) to your hard drive into a new [load package](../../general-usage/destination-tables#load-packages-and-load-ids), which will be assigned a unique ID and will contain your raw data as received from your sources. Additionally, you can [supply schema hints](../../general-usage/resource#define-schema) to define the data types of some of the columns or add a primary key and unique indexes. You can also control this phase by [limiting](../../general-usage/resource#sample-from-large-data) the number of items extracted in one run, using [incremental cursor fields](../../general-usage/incremental-loading#incremental-loading-with-a-cursor-field), and by tuning the performance with [parallelization](../../reference/performance#extract). You can also apply filters and maps to [obfuscate](../../general-usage/customising-pipelines/pseudonymizing_columns) or [remove](../../general-usage/customising-pipelines/removing_columns) personal data, and you can use [transformers](../../examples/transformers) to create derivative data. + +### Normalize + +Normalize can be run individually with the `normalize` command on the pipeline. Normalize is dependent on having a completed extract phase and will not do anything if there is no extracted data. + +```py +pipeline.normalize() +``` + +During the normalization phase, `dlt` inspects and normalizes your data and computes a [schema](../../general-usage/schema) corresponding to the input data. The schema will automatically evolve to accommodate any future source data changes like new columns or tables. `dlt` will also unnest nested data structures into child tables and create variant columns if detected values do not match a schema computed during a previous run. The result of the normalization phase is an updated load package that holds your normalized data in a format your destination understands and a full schema which can be used to migrate your data to your destination. You can control the normalization phase, for example, by [defining the allowed nesting level](../../general-usage/source#reduce-the-nesting-level-of-generated-tables) of input data, by [applying schema contracts](../../general-usage/schema-contracts) that govern how the schema might evolve, and how rows that do not fit are treated. Performance settings are [also available](../../reference/performance#normalize). + +### Load + +Load can be run individually with the `load` command on the pipeline. Load is dependent on having a completed normalize phase and will not do anything if there is no normalized data. + +```py +pipeline.load() +``` + +During the loading phase, `dlt` first runs schema migrations as needed on your destination and then loads your data into the destination. `dlt` will load your data in smaller chunks called load jobs to be able to parallelize large loads. If the connection to the destination fails, it is safe to rerun the pipeline, and `dlt` will continue to load all load jobs from the current load package. `dlt` will also create special tables that store the internal dlt schema, information about all load packages, and some state information which, among other things, are used by the incrementals to be able to restore the incremental state from a previous run to another machine. Some ways to control the loading phase are by using different [`write_dispositions`](../../general-usage/incremental-loading#choosing-a-write-disposition) to replace the data in the destination, simply append to it, or merge on certain merge keys that you can configure per table. For some destinations, you can use a remote staging dataset on a bucket provider, and `dlt` even supports modern open table formats like [deltables and iceberg](../../dlt-ecosystem/destinations/delta-iceberg), and [reverse ETL](../../dlt-ecosystem/destinations/destination) is also possible. + +## Other notable `dlt` features + +* `dlt` is simply a Python package, so it will run [everywhere that Python runs](../../walkthroughs/deploy-a-pipeline) — locally, in notebooks, on orchestrators — you name it. +* `dlt` allows you to build and test your data pipelines locally with `duckdb` and then switch out the destination for deployment. +* `dlt` provides a user-friendly interface for [accessing your data in Python](../../general-usage/dataset-access/dataset), using [a Streamlit app](../../general-usage/dataset-access/streamlit), and leveraging [integrations](../../general-usage/dataset-access/ibis-backend) with the fabulous Ibis library. All of this even works on data lakes provided by bucket storage providers. +* `dlt` fully manages schema migrations on your destinations. You don’t even need to know how to use SQL to update your schema. It also supports [schema contracts](../../general-usage/schema-contracts) to govern how the schema might evolve. +* `dlt` offers numerous options for [monitoring and tracing](../../running-in-production/monitoring) what is happening during your loads. +* `dlt` supports you when you need to [transform your data](../../dlt-ecosystem/transformations) after the load, whether with dbt or in Python using Arrow tables and pandas DataFrames. diff --git a/docs/website/static/img/dlt-onepager.png b/docs/website/static/img/dlt-onepager.png new file mode 100644 index 0000000000..57b5d3f658 Binary files /dev/null and b/docs/website/static/img/dlt-onepager.png differ