Function import_command

sdk/python/feast/cli/dbt_import.py:91–328

Import dbt models as Feast FeatureViews. This command parses a dbt manifest.json file and creates corresponding Feast DataSource and FeatureView objects. Examples: # Import all models with 'feast' tag feast dbt import -m target/manifest.json -e driver_id --tag fea

(
    ctx: click.Context,
    manifest_path: str,
    entity_columns: tuple,
    data_source_type: str,
    timestamp_field: str,
    tag_filter: Optional[str],
    model_names: tuple,
    ttl_days: int,
    dry_run: bool,
    exclude_columns: Optional[str],
    output: Optional[str],
)

)
@click.pass_context
def import_command(
    ctx: click.Context,
    manifest_path: str,
    entity_columns: tuple,
    data_source_type: str,
    timestamp_field: str,
    tag_filter: Optional[str],
    model_names: tuple,
    ttl_days: int,
    dry_run: bool,
    exclude_columns: Optional[str],
    output: Optional[str],
):
    """
    Import dbt models as Feast FeatureViews.

    This command parses a dbt manifest.json file and creates corresponding
    Feast DataSource and FeatureView objects.

    Examples:

        # Import all models with 'feast' tag
        feast dbt import -m target/manifest.json -e driver_id --tag feast

        # Import specific models
        feast dbt import -m target/manifest.json -e customer_id --model orders --model customers

        # Dry run to preview changes
        feast dbt import -m target/manifest.json -e driver_id --tag feast --dry-run

        # Generate Python file instead of applying to registry
        feast dbt import -m target/manifest.json -e driver_id --tag feast --output features.py
    """
    from feast.dbt.mapper import DbtToFeastMapper
    from feast.dbt.parser import DbtManifestParser

    # Parse manifest
    click.echo(f"{Fore.CYAN}Parsing dbt manifest: {manifest_path}{Style.RESET_ALL}")

    try:
        parser = DbtManifestParser(manifest_path)
        parser.parse()
    except FileNotFoundError as e:
        click.echo(f"{Fore.RED}Error: {e}{Style.RESET_ALL}", err=True)
        raise SystemExit(1)
    except ValueError as e:
        click.echo(f"{Fore.RED}Error: {e}{Style.RESET_ALL}", err=True)
        raise SystemExit(1)

    # Display manifest info
    if parser.dbt_version:
        click.echo(f"  dbt version: {parser.dbt_version}")
    if parser.project_name:
        click.echo(f"  Project: {parser.project_name}")

    # Convert tuple to list and validate
    entity_cols: List[str] = list(entity_columns) if entity_columns else []