Poznámka:
Přístup k této stránce vyžaduje autorizaci. Můžete se zkusit přihlásit nebo změnit adresáře.
Přístup k této stránce vyžaduje autorizaci. Můžete zkusit změnit adresáře.
Important
Podpora deklarativních automatizačních balíčků pro Lakebase je v beta fázi.
Tato stránka ukazuje kompletní balíček Declarative Automation Bundles pro produkčně připravený projekt Lakebase s nejčastěji používanými funkcemi:
- Chráněná produkční větev
- Koncový bod s vysokou dostupností pro čtení a zápis s čitelnými sekundárními soubory
- Vložené oprávnění na úrovni pracovního prostoru
CAN_MANAGEpro instanční objekt služby - Průběžné streamování tabulek z katalogu Unity
- Propojení Unity Catalog pro databázi Lakebase
- Aplikace Databricks připojená k projektu Lakebase
Podrobný návod krok za krokem k deklarativním balíčkům automatizace v Lakebase najdete v tématu Správa Lakebase pomocí deklarativních balíčků automatizace.
Prerequisites
Než začnete, potřebujete:
- Databricks CLI verze 1.0.0 nebo novější Pokud chcete zkontrolovat verzi, spusťte
databricks --versionpříkaz . Pokud chcete nainstalovat nebo upgradovat, přečtěte si téma Instalace nebo aktualizace rozhraní příkazového řádku Databricks. - Pracovní prostor Azure Databricks s povolenou službou Lakebase.
- Instanční objekt nakonfigurovaný pro ověřování OAuth typu mezi počítači (M2M). Sada uděluje tomuto hlavnímu pracovnímu prostoru
CAN_MANAGEoprávnění k projektu. Viz Autorizace přístupu instančního objektu k Azure Databricks pomocí oprávnění OAuth a správa projektu. - Tabulka Delta v Unity Catalogu s povolenou funkcí Change Data Feed (CDF), která se použije jako zdroj synchronizace. Odeberte bloky
postgres_synced_tablesapostgres_catalogs, pokud nepotřebujete synchronizaci dat.
Dokončení konfigurace sady
Sada používá proměnné pro všechny hodnoty specifické pro pracovní prostor. Nastavte je v .databricks/bundle/<target>/variables.json souboru nebo je předejte v době nasazení pomocí --var.
Když vytvoříte projekt, Azure Databricks automaticky vytvoří production větev, primary koncový bod pro čtení i zápis, roli Postgres vlastníka svázanou s vaší identitou databricks_postgres a databázi. Chcete-li nakonfigurovat tyto implicitně vytvořené prostředky, deklarujte je pomocí replace_existing: true.
bundle:
name: lakebase-typical-project
variables:
project_id:
description: 'Lakebase project ID (lowercase, hyphen-delimited)'
default: 'my-lakebase-project'
display_name:
description: 'Human-readable project name shown in the UI'
default: 'My Lakebase project'
pg_version:
description: 'Postgres major version'
default: 17
min_cu:
description: 'Minimum compute units on the default endpoint'
default: 0.5
max_cu:
description: 'Maximum compute units on the default endpoint'
default: 4.0
suspend_timeout:
description: 'Idle time before the default endpoint suspends. Ignored when no_suspension is true.'
default: '300s'
admin_sp_app_id:
description: 'Application ID of the service principal to grant CAN_MANAGE on the project'
default: '<your-sp-application-id>'
source_table:
description: 'Unity Catalog three-part name of the Delta table to sync (catalog.schema.table)'
default: '<catalog>.<schema>.<table>'
primary_key_column:
description: 'Primary key column of the source Delta table'
default: '<pk>'
storage_catalog:
description: 'Unity Catalog catalog where the sync pipeline stores its metadata'
default: '<catalog>'
storage_schema:
description: 'Unity Catalog schema where the sync pipeline stores its metadata'
default: '<schema>'
app_name:
description: 'Databricks App name (must be unique in the workspace)'
default: 'my-lakebase-app'
uc_catalog_id:
description: 'Name to register the Lakebase database in Unity Catalog'
default: 'my_lakebase_uc_catalog'
database_name:
description: 'Postgres-internal name for the app database'
default: 'app_database'
targets:
prod:
default: true
workspace:
host: https://<your-workspace>.cloud.databricks.com
resources:
# Project — top-level container for branches, endpoints, and databases.
# The permissions block grants workspace-level CAN_MANAGE to the service principal.
postgres_projects:
lakebase_project:
project_id: ${var.project_id}
# purge_on_delete: true # Uncomment to permanently delete on destroy (default: soft delete, 7-day retention).
pg_version: ${var.pg_version}
display_name: ${var.display_name}
default_endpoint_settings:
autoscaling_limit_min_cu: ${var.min_cu}
autoscaling_limit_max_cu: ${var.max_cu}
suspend_timeout_duration: ${var.suspend_timeout}
permissions:
- service_principal_name: ${var.admin_sp_app_id}
level: CAN_MANAGE
# Configure the implicitly created production branch as protected.
postgres_branches:
production:
branch_id: production
parent: ${resources.postgres_projects.lakebase_project.name}
no_expiry: true
is_protected: true
replace_existing: true
# Configure the implicitly created primary endpoint with HA.
# HA requires no_suspension: true. group.min: 2 adds a standby for automatic failover.
postgres_endpoints:
primary:
endpoint_id: primary
parent: ${resources.postgres_branches.production.name}
endpoint_type: ENDPOINT_TYPE_READ_WRITE
autoscaling_limit_min_cu: ${var.min_cu}
autoscaling_limit_max_cu: ${var.max_cu}
no_suspension: true
group:
min: 2
max: 2
enable_readable_secondaries: true
replace_existing: true
# Postgres role that owns the app database.
postgres_roles:
app_role:
role_id: app-role # Resource ID: lowercase letters, digits, and hyphens.
parent: ${resources.postgres_branches.production.name}
postgres_role: app_role # Postgres identifier: lowercase letters, digits, and underscores.
# Named Postgres database for the app.
postgres_databases:
app_db:
database_id: app-database
parent: ${resources.postgres_branches.production.name}
postgres_database: ${var.database_name}
role: ${resources.postgres_roles.app_role.id}
# Sync a Unity Catalog Delta table into the project continuously.
postgres_synced_tables:
orders_sync:
synced_table_id: '${var.storage_catalog}.${var.storage_schema}.orders_synced'
branch: ${resources.postgres_branches.production.name}
postgres_database: ${var.database_name}
source_table_full_name: ${var.source_table}
primary_key_columns:
- ${var.primary_key_column}
scheduling_policy: CONTINUOUS
create_database_objects_if_missing: true
new_pipeline_spec:
storage_catalog: ${var.storage_catalog}
storage_schema: ${var.storage_schema}
# Bind the Lakebase database into Unity Catalog so it is queryable as UC data.
postgres_catalogs:
lakebase_uc_catalog:
catalog_id: ${var.uc_catalog_id}
postgres_database: ${var.database_name}
branch: ${resources.postgres_branches.production.name}
create_database_if_missing: true
# Databricks App connected to the project.
# Update source_code_path to point to your app source directory.
apps:
lakebase_app:
name: ${var.app_name}
description: 'App backed by Lakebase autoscaling'
source_code_path: ./app_src
config:
command:
- flask
- run
- --host=0.0.0.0
- --port=8000
resources:
- name: lakebase-db
postgres:
branch: ${resources.postgres_branches.production.name}
database: ${resources.postgres_databases.app_db.name}
permission: CAN_CONNECT_AND_CREATE
Note
Každý projekt Lakebase automaticky vytvoří databricks_postgres databázi vlastněnou rolí Postgres svázanou s vaší identitou. Tento balíček místo toho vytvoří samostatnou databázi s názvem (${var.database_name}), kterou vlastní vyhrazená aplikační role, aby se izolovala data aplikace. Pokud chcete implicitní databázi a roli použít přímo, odeberte bloky prostředků postgres_roles a postgres_databases, nastavte postgres_database: databricks_postgres přímo na postgres_synced_tables a postgres_catalogs a aktualizujte prostředek aplikace na database: ${resources.postgres_branches.production.name}/databases/databricks-postgres.
Pokud chcete implicitní roli vlastníka a databázi databricks_postgres místo toho zahrnout do správy balíčku, deklarujte je pomocí replace_existing: true s využitím jejich stávajících ID. ID databáze je vždy databricks-postgres. ID role se odvozuje z vaší identity v Databricks, nikoli z pevně daného názvu, proto jej nejprve vyhledejte:
databricks postgres list-roles projects/<project-id>/branches/production
Poté deklarujte oba zdroje tak, aby odpovídaly všem polím, která jsou už u role nastavena. Vynechání odebere membership_roles členství z role při jeho přijetí, takže ho explicitně deklarujteDATABRICKS_SUPERUSER:
postgres_roles:
owner:
role_id: <role-id-from-list-roles>
parent: ${resources.postgres_branches.production.name}
postgres_role: user@databricks.com # Or the service principal application ID.
identity_type: USER # Or SERVICE_PRINCIPAL.
membership_roles:
- DATABRICKS_SUPERUSER
replace_existing: true
postgres_databases:
databricks_postgres:
database_id: databricks-postgres
parent: ${resources.postgres_branches.production.name}
postgres_database: databricks_postgres
role: ${resources.postgres_roles.owner.id}
replace_existing: true
Note
Chcete-li odstranit prostředky, které tento balíček vytvoří, spusťte příkaz databricks bundle destroy -t prod. Ve výchozím nastavení je projekt měkce odstraněn a před trvalým odstraněním je uchováván po dobu 7 dnů, takže ho můžete během doby uchování obnovit. Pokud chcete odstranit pouze projekt okamžitě, použijte rozhraní příkazového řádku Databricks s příkazem --purgenebo zrušte komentář purge_on_delete: true ve výše uvedeném zdroji projektu a pevně ho odstraňte při každém zničení:
databricks postgres delete-project projects/<project-id> --purge
Použití sady
Ověření a nasazení:
databricks bundle validate -t prod
databricks bundle deploy -t prod
Pokud databricks bundle deploy se při prvním spuštění nedokončí, spusťte ho znovu.
Co se nasazuje
Sada vytvoří následující prostředky:
- Projekt Lakebase s výchozími výpočetními parametry, které jste specifikovali.
- Chráněná
productionvětev. - Primární koncový bod pro čtení i zápis s vysokou dostupností a čitelnými sekundárními soubory.
- Kanál průběžné synchronizace, který streamuje tabulku Unity Catalog Delta do databáze projektu.
- Katalog Unity založený na databázi Lakebase, který je možné dotazovat jako data katalogu Unity.
- Aplikace Databricks připojená k databázi projektu.
- Oprávnění pracovního prostoru
CAN_MANAGEpro zadaný instanční objekt služby.
Další zdroje informací
- Vysoká dostupnost zahrnuje vzory vysoké dostupnosti a kdy je používat v produkčním prostředí.
- Obsluha dat lakehouse se synchronizovanými tabulkami pokrývá možnosti plánování a správu kanálů.
- Správa oprávnění projektu zahrnuje řízení přístupu na úrovni pracovního prostoru a na úrovni databáze.
- Připojení vlastní aplikace Databricks k Lakebase ukazuje, jak připojit Databricks Apps k projektům automatického škálování.
- Prostředky Declarative Automation Bundles obsahují úplnou referenční příručku k prostředkům Declarative Automation Bundles.