Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: Add Snowflake online store (again) (#2922)
* feat: Add snowflake online store Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * lint/format Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * removing missing testing env variables Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * test offline store first Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * snowflake online test fixes Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * format Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * fix snowflake testing (#2903) Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * change to transient table Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * remove extra lines Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * docs + nits Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * docs + nits2 Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * final docs + nits Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * Update sdk/python/feast/infra/online_stores/snowflake.py Co-authored-by: Achal Shah <achals@gmail.com> Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * Update sdk/python/feast/infra/online_stores/snowflake.py Co-authored-by: Achal Shah <achals@gmail.com> Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * Update sdk/python/feast/infra/online_stores/snowflake.py Co-authored-by: Achal Shah <achals@gmail.com> Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * Update sdk/python/feast/infra/online_stores/snowflake.py Co-authored-by: Achal Shah <achals@gmail.com> Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * fix serialization Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> * fix serialization2 Signed-off-by: Miles Adkins <miles.adkins@snowflake.com> Co-authored-by: Achal Shah <achals@gmail.com>
- Loading branch information
1 parent
61a194c
commit 2ef71fc
Showing
15 changed files
with
542 additions
and
37 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,35 @@ | ||
# Snowflake | ||
|
||
## Description | ||
|
||
The [Snowflake](https://trial.snowflake.com) online store provides support for materializing feature values into a Snowflake Transient Table for serving online features. | ||
|
||
* Only the latest feature values are persisted | ||
|
||
The data model for using a Snowflake Transient Table as an online store follows a tall format (one row per feature)): | ||
* "entity_feature_key" (BINARY) -- unique key used when reading specific feature_view x entity combination | ||
* "entity_key" (BINARY) -- repeated key currently unused for reading entity_combination | ||
* "feature_name" (VARCHAR) | ||
* "value" (BINARY) | ||
* "event_ts" (TIMESTAMP) | ||
* "created_ts" (TIMESTAMP) | ||
|
||
(This model may be subject to change when Snowflake Hybrid Tables are released) | ||
|
||
## Example | ||
|
||
{% code title="feature_store.yaml" %} | ||
```yaml | ||
project: my_feature_repo | ||
registry: data/registry.db | ||
provider: local | ||
online_store: | ||
type: snowflake.online | ||
account: SNOWFLAKE_DEPLOYMENT_URL | ||
user: SNOWFLAKE_USER | ||
password: SNOWFLAKE_PASSWORD | ||
role: SNOWFLAKE_ROLE | ||
warehouse: SNOWFLAKE_WAREHOUSE | ||
database: SNOWFLAKE_DATABASE | ||
``` | ||
{% endcode %} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.