feature_store_py.fs_project

class feature_store_py.fs_project.FeatureStoreProject(api_client, project_id, project_name, offline_datasource_id, online_datasource_id, offline_datasource_type=None, online_datasource_type=None, summary=None)

基类:FsProjectApi, FeatureStore

Build FeatureStoreClient.

change_hot_ids_version(feature_entity_name, version)

Change hot ids version.

参数:
  • feature_entity_name (string) – feature enetity name.

  • version (string) – version for hot ids.

返回:

None

create_batch_feature_view(name, owner, schema=None, datasource=None, online=False, entity=None, primary_key='', event_time='', ttl=-1, partitions=[], tags=[], type='batch', register=False, config={})
create_entity(name, join_id)

Create feature store entity. @param: name string @param: join_id string

create_feature_view(name, owner, schema=None, datasource=None, online=False, entity=None, primary_key='', event_time='', ttl=-1, partitions=[], tags=[], type='batch', register=False, config={})

Create batch feature view. @param: name string

create_label_table(owner, datasource=None, schema=None, feature_fields=[], fg_reserve_fields=[], event_time='', label_fields=[])
create_model(name, owner, training_set, deploy_config=None)
create_stream_feature_view(name, owner, schema=None, datasource=None, online=False, entity=None, primary_key='', event_time='', ttl=-1, partitions=[], tags=[], type='stream', register=True, config={'save_original_field': True})

Create stream feature view. @param: name string

create_train_set_table(model_name, train_set, model_features)
create_training_set(label_input=None, train_set_output=None, feature_selectors=[], label_table_name=None)
delete_entity(name)

Delete feature store entity @param: name string

delete_feature_view(name)
delete_label_table(name)
delete_model(name)
delete_model_by_id(id)
get_entity(name)
get_entity_body(name)
get_feature_view(name)
get_label_table(name)
get_model(name)
get_model_by_id(id)
get_model_by_model_data(model_data)
get_online_features(join_ids={}, feauture_selectors=[])
get_project_api()
list_hot_ids(feature_entity_name, output_file=None, limit=None)
property offline_datasoruce_id
property online_datasource_id
parse_feature_selectors(feature_selectors)
property project_id
property project_name
to_str()
write_hot_ids(feature_entity_name, version, hot_ids)