Migrieren von Legacy- und Drittanbieter-Onlinetabellen

Auf dieser Seite wird beschrieben, wie Sie Ihre vorhandenen Databricks-Onlinetabellen (Legacy) migrieren. Sie können zu folgendem Migrieren migrieren:

• Ein Online-Featurespeicher
• Synchronisierte Lakebase-Tabelle

Alle vorhandenen Onlinetabellen auflisten

Um alle vorhandenen Onlinetabellen in Ihrem Arbeitsbereich anzuzeigen, verwenden Sie eine SQL-Abfrage oder ein Python-Skript.

SQL

Ersetzen Sie sowohl <workspace_url> als auch <workspace_id> durch Ihre Arbeitsbereichsinformationen.

SELECT
  CONCAT("https://<workspace_url>/pipelines/", usage_metadata.dlt_pipeline_id, "?o=<workspace_id>"),
  SUM(usage_quantity)
FROM
  system.billing.usage
WHERE
  usage_date > DATE_SUB(NOW(), 7)
  AND billing_origin_product = 'ONLINE_TABLES'
GROUP BY
  ALL;

Python

from databricks.sdk import *
from databricks.sdk.service.catalog import *

w = WorkspaceClient()

result = []
for catalog in w.catalogs.list():
    for schema in w.schemas.list(catalog_name=catalog.name):
        for table in w.tables.list(catalog_name=catalog.name, schema_name=schema.name):
            if table.table_type == TableType.FOREIGN and table.data_source_format == DataSourceFormat.MYSQL_FORMAT and table.pipeline_id is not None:
                result.append((table.full_name, table.comment))

print(result)

Migrieren von Onlinetabellen zum Onlinefeaturespeicher für Modell- oder Featurebereitstellungsendpunkte

Schritt 1: Erstellen eines Onlinefeaturespeichers und Veröffentlichen der Featuretabellen

Databricks empfiehlt die Erstellung eines einzelnen Online-Stores für jeden Arbeitsbereich zum Testen und Machbarkeitsnachweis. Für Produktionsumgebungen oder Isolierungsanforderungen können Sie zusätzliche Speicher bereitstellen.

from databricks.feature_engineering import FeatureEngineeringClient

fe = FeatureEngineeringClient()

# Create a single online store that can support multiple feature tables
fe.create_online_store(
    name="online-feature-store",
    capacity="CU_1"
)

Weitere Informationen zum Veröffentlichen von Funktionstabellen finden Sie unter Databricks Online Feature Stores.

Schritt 2: Aktualisieren des Endpunkts, der von diesen Onlinefeatures abhängt

Verwenden Sie databricks SDK für Python oder die Benutzeroberfläche, um den Endpunkt mit einer neuen Umgebungsvariable MIGRATE_FEATURE_STORE mit dem aktuellen Datum als Wert zu aktualisieren.

from databricks.sdk import WorkspaceClient
from databricks.sdk.service.serving import EndpointCoreConfigInput, ServedEntityInput

workspace = WorkspaceClient()

workspace.serving_endpoints.update_config(
  name="my-serving-endpoint",
  served_entities=[
    ServedEntityInput(
      entity_name="main.default.customer_features",
      workload_size="Small",
      scale_to_zero_enabled=True,
      environment_vars={
        # Set to the current date (optional time) to indicate migration to online store
        # This environment variable can be removed after January 15, 2026.
        "MIGRATE_FEATURE_STORE": "2025-11-13"
      }
    )
  ]
)

Ausführliche Informationen finden Sie unter "Aktualisieren eines Endpunkts".

Schritt 3: Bereinigen Ihrer Onlinetabellen

Überprüfen Sie, ob der Endpunkt den neuen Onlinespeicher verwendet, indem Sie überprüfen, ob die Endpunktereignisse Nachrichten wie Linked to Online Feature Store table: "table name". Siehe Überwachen der Modellqualität und Endpunktintegrität.

Löschen Sie als Nächstes Ihre älteren Onlinetabellen. Siehe Löschen einer Onlinetabelle mithilfe der Benutzeroberfläche oder Löschen einer Onlinetabelle mithilfe von APIs.

Migrieren von Onlinetabellen zu synchronisierten Tabellen für OLTP

Schritt 1: Erstellen einer Datenbankinstanz

Erstellen Sie zunächst eine Lakebase-Datenbankinstanz, um Ihre synchronisierten Tabellen zu speichern. Siehe Erstellen und Verwalten einer Datenbankinstanz.

Optional können Sie einen Datenbankkatalog erstellen, um Unity-Katalogberechtigungen zum Verwalten des Datenzugriffs zu verwenden. Siehe Registrieren Ihrer Datenbank im Unity-Katalog.

Schritt 2: Erstellen einer synchronisierten Tabelle aus der Quelltabelle

Eine synchronisierte Tabelle ist eine schreibgeschützte Postgres-Tabelle im Unity Catalog, die automatisch Daten aus einer Unity-Katalog-Tabelle mit Ihrer Lakebase-Datenbankinstanz synchronisiert.

Um aus Onlinetabellen zu synchronisierten Tabellen zu synchronisierten Tabellen zu migrieren, erstellen Sie eine synchronisierte Tabelle aus der Quelltabelle einer Onlinetabelle:

1. Im Katalog, wählen Sie die Onlinetabelle aus, die Sie zu einer synchronisierten Tabelle migrieren möchten.
2. Klicken Sie auf der Registerkarte "Übersicht " unter dem Abschnitt "Beschreibung " auf den Namen der Quelltabelle.
3. Erstellen Sie eine synchronisierte Tabelle aus der ausgewählten Quelltabelle. Siehe "Synchronisieren von Daten aus Unity Catalog-Tabellen mit einer Datenbankinstanz".
   • Sie können die synchronisierte Tabelle an demselben Katalogspeicherort wie die vorhandene Onlinetabelle speichern.
   • Sie können eine Pipeline zwischen synchronisierten Tabellen freigeben.
4. Nachdem Ihre synchronisierte Tabelle erstellt wurde, können Sie eine Verbindung mit der Datenbankinstanz herstellen und sie direkt abfragen. Siehe Verbinden und Abfragen.

Schritt 3: Bereinigen Ihrer Onlinetabellen

Nachdem Sie Ihre synchronisierten Tabellen erstellt haben, löschen Sie Ihre Onlinetabellen. Siehe Löschen einer Onlinetabelle mithilfe der Benutzeroberfläche oder Löschen einer Onlinetabelle mithilfe von APIs.