Merge ccfd62e into 65e3f13

whylabs · Feb 23, 2022 · e9b7d64 · e9b7d64
2 parents 65e3f13 + ccfd62e
commit e9b7d64
Show file tree

Hide file tree

Showing 9 changed files with 6,853 additions and 0 deletions.
diff --git a/examples/feast_whylogs_example/feast_whylogs.ipynb b/examples/feast_whylogs_example/feast_whylogs.ipynb
diff --git a/examples/feast_whylogs_example/feature_repo/__init__.py b/examples/feast_whylogs_example/feature_repo/__init__.py
diff --git a/examples/feast_whylogs_example/feature_repo/data/driver_stats.parquet b/examples/feast_whylogs_example/feature_repo/data/driver_stats.parquet
diff --git a/examples/feast_whylogs_example/feature_repo/data/nyc_taxi_rides_feb_2020.parquet b/examples/feast_whylogs_example/feature_repo/data/nyc_taxi_rides_feb_2020.parquet
diff --git a/examples/feast_whylogs_example/feature_repo/example.py b/examples/feast_whylogs_example/feature_repo/example.py
@@ -0,0 +1,38 @@
+# This is an example feature definition file
+
+from feast import Entity, Feature, FeatureView, FileSource, ValueType
+from google.protobuf.duration_pb2 import Duration
+
+# Read data from parquet files. Parquet is convenient for local development mode. For
+# production you can use your favorite DWH, such as BigQuery. See Feast documentation
+# for more info.
+driver_hourly_stats = FileSource(
+    path="/work/feature_repo/data/driver_stats.parquet",
+    event_timestamp_column="event_timestamp",
+    created_timestamp_column="created",
+)
+
+# Define an entity for the driver. You can think of entity as a primary key used to
+# fetch features.
+driver = Entity(
+    name="driver_id",
+    value_type=ValueType.INT64,
+    description="driver id",
+)
+
+# Our parquet files contain sample data that includes a driver_id column, timestamps and
+# three feature column. Here we define a Feature View that will allow us to serve this
+# data to our model online.
+driver_hourly_stats_view = FeatureView(
+    name="driver_hourly_stats",
+    entities=["driver_id"],
+    ttl=Duration(seconds=86400 * 1),
+    features=[
+        Feature(name="rate_1m", dtype=ValueType.INT64),
+        Feature(name="avg_daily_trips", dtype=ValueType.INT64),
+        Feature(name="avg_speed", dtype=ValueType.FLOAT),
+    ],
+    online=True,
+    batch_source=driver_hourly_stats,
+    tags={},
+)
diff --git a/examples/feast_whylogs_example/feature_repo/feature_store.yaml b/examples/feast_whylogs_example/feature_repo/feature_store.yaml
@@ -0,0 +1,5 @@
+project: feature_repo
+registry: data/registry.db
+provider: local
+online_store:
+    path: data/online_store.db
diff --git a/examples/feast_whylogs_example/images/context.jpg b/examples/feast_whylogs_example/images/context.jpg
diff --git a/examples/feast_whylogs_example/images/profile_viewer.png b/examples/feast_whylogs_example/images/profile_viewer.png
diff --git a/examples/feast_whylogs_example/nyc_taxi_rides_feb_2020.parquet b/examples/feast_whylogs_example/nyc_taxi_rides_feb_2020.parquet