Migrera från äldre onlinetabeller och onlinetabeller från tredje part

Den här sidan beskriver hur du migrerar dina befintliga Databricks-onlinetabeller (äldre). Du kan migrera till följande:

• En funktionsbutik online
• En Lakebase-synkroniserad tabell

Visa en lista över alla befintliga onlinetabeller

Om du vill se alla befintliga onlinetabeller på din arbetsyta använder du en SQL-fråga eller ett Python-skript.

SQL

Ersätt <workspace_url> och <workspace_id> med din arbetsyteinformation.

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)

Migrera onlinetabeller till onlinefunktionsarkivet för modell- eller funktionsserverslutpunkter

Steg 1: Skapa en onlinefunktionsbutik och publicera funktionstabellerna

Mer information finns i Databricks Online Feature Stores.

Steg 2: Uppdatera slutpunkten som är beroende av dessa onlinefunktioner

Använd API:et, Databricks SDK för Python eller användargränssnittet för att uppdatera slutpunkten. Om du använder kommandot API eller Databricks SDK för Python behöver du inte ändra dina indata. Mer information finns i Uppdatera en slutpunkt.

Steg 3: Rensa dina onlinetabeller

Kontrollera att slutpunkten använder den nya onlinebutiken genom att kontrollera om slutpunktshändelserna innehåller meddelanden som Linked to Online Feature Store table: "table name". Se Övervaka modellkvalitet och slutpunktshälsa.

Ta sedan bort dina äldre onlinetabeller. Se Ta bort en onlinetabell med hjälp av användargränssnittet eller Ta bort en onlinetabell med API:er.

Migrera onlinetabeller till synkroniserade tabeller för OLTP

Steg 1: Skapa en databasinstans

Börja med att skapa en Lakebase-databasinstans för att lagra dina synkroniserade tabeller. Se Skapa och hantera en databasinstans.

Du kan också skapa en databaskatalog för att använda Unity Catalog-behörigheter för att hantera dataåtkomst. Seé Registrera din databas i Unity Catalog.

Steg 2: Skapa en synkroniserad tabell från källtabellen

En synkroniserad tabell är en skrivskyddad Postgres-tabell i Unity Catalog som automatiskt synkroniserar data från en Unity Catalog-tabell till lakebase-databasinstansen.

Om du vill migrera från onlinetabeller till synkroniserade tabeller skapar du en synkroniserad tabell från källtabellen i en onlinetabell:

1. I Välj den onlinetabell som du vill migrera till en synkroniserad tabell.
2. Klicka på namnet på tabellen Källa under avsnittet Beskrivning på fliken Översikt.
3. Skapa en synkroniserad tabell från den valda källtabellen. Se Synkronisera data från Unity Catalog-tabeller till en databasinstans.
   • Du kan lagra den synkroniserade tabellen på samma katalogplats som den befintliga onlinetabellen.
   • Du kan dela en pipeline mellan synkroniserade tabeller.
4. När den synkroniserade tabellen har skapats kan du ansluta till databasinstansen och fråga den direkt. Se Ansluta och fråga.

Steg 3: Rensa dina onlinetabeller

När du har skapat dina synkroniserade tabeller tar du bort dina onlinetabeller. Se Ta bort en onlinetabell med hjälp av användargränssnittet eller Ta bort en onlinetabell med API:er.