Function materialize_command

sdk/python/feast/cli/cli.py:372–417

Run a (non-incremental) materialization job to ingest data into the online store. Feast will read all data between START_TS and END_TS from the offline store and write it to the online store. If you don't specify feature view names using --views, all registered Feature Views will be

(
    ctx: click.Context,
    start_ts: Optional[str],
    end_ts: Optional[str],
    views: List[str],
    disable_event_timestamp: bool,
    feature_view_version: Optional[str],
)

)
@click.pass_context
def materialize_command(
    ctx: click.Context,
    start_ts: Optional[str],
    end_ts: Optional[str],
    views: List[str],
    disable_event_timestamp: bool,
    feature_view_version: Optional[str],
):
    """
    Run a (non-incremental) materialization job to ingest data into the online store. Feast
    will read all data between START_TS and END_TS from the offline store and write it to the
    online store. If you don't specify feature view names using --views, all registered Feature
    Views will be materialized.

    START_TS and END_TS should be in ISO 8601 format, e.g. '2021-07-16T19:20:01'

    If --disable-event-timestamp is used, timestamps are not required and all available data will be materialized using the current datetime as the event timestamp.
    """
    store = create_feature_store(ctx)

    if disable_event_timestamp:
        if start_ts or end_ts:
            raise click.UsageError(
                "Cannot specify START_TS or END_TS when --disable-event-timestamp is used"
            )
        now = datetime.now()
        # Query all available data and use current datetime as event timestamp
        start_date = datetime(
            1970, 1, 1
        )  # Beginning of time to capture all historical data
        end_date = now
    else:
        if not start_ts or not end_ts:
            raise click.UsageError(
                "START_TS and END_TS are required unless --disable-event-timestamp is used"
            )
        start_date = utils.make_tzaware(parser.parse(start_ts))
        end_date = utils.make_tzaware(parser.parse(end_ts))

    store.materialize(
        feature_views=None if not views else views,
        start_date=start_date,
        end_date=end_date,
        disable_event_timestamp=disable_event_timestamp,
        version=feature_view_version,
    )


@cli.command("materialize-incremental")