Closed andrijaperovic closed 2 years ago
Following along with the offline_to_online_ingestion and get_online_features example: https://github.com/Azure/feast-azure/blob/main/cluster/samples/feature_store_azure.ipynb
The offline_to_online_ingestion job completes successfully. Defining max_age as Duration(seconds=3600*24*365) in the FeatureTable definition.
offline_to_online_ingestion
max_age
Duration(seconds=3600*24*365)
FeatureTable
When running:
features = client.get_online_features( feature_refs=["driver_statistics:avg_daily_trips"], entity_rows=entities_with_timestamp[["driver_id"]].T.to_dict().values()).to_dict() print("\nFeatures Output:\n") print(pd.DataFrame.from_dict(features).head())
Getting the following output:
Features Output: driver_statistics:avg_daily_trips driver_id 0 None 819469 1 None 707266 2 None 675300 3 None 423393 4 None 515239
I do however see records being inserted into Redis when running MONITOR on the cluster:
MONITOR
643878326.245889 [0 20.185.145.229:1025] "HSET" "\n\x14transactionspoctest3\x12\border_id\x1a\x06 \xc8\xdd\xc8\xd7\x04" "_ts:transactions" "\b\xeb\xf3\xf5\x88\x06" "h\xd14\xa8" " \x01" "_ex:transactions" "\b\xeb\x96\xfb\x88\x06" "\x10\xc6\x8a\xe1" "\x12$fe0ef041-f760-39f8-bc23-50c14a0190e0" "\x0f\x90Q\"" " \r" "\x9a\x1c\xa0\x0b" "\x12\x03GBP" "\"/\x021" ")333333\xf3?
Saw this thread: https://github.com/feast-dev/feast/issues/1300#issuecomment-771945343 ++ @snowmanmsft
Following along with the offline_to_online_ingestion and get_online_features example: https://github.com/Azure/feast-azure/blob/main/cluster/samples/feature_store_azure.ipynb
The
offline_to_online_ingestion
job completes successfully. Definingmax_age
asDuration(seconds=3600*24*365)
in theFeatureTable
definition.When running:
Getting the following output:
I do however see records being inserted into Redis when running
MONITOR
on the cluster: