Add Flow to the example DWH

README.md

@@ -8,6 +8,7 @@
 
 * [Basic hNhM concepts](#basic-hnhm-concepts)
 * [Quick Start](#quick-start)
+* [DWH example](#dwh-example)
 * [Guide](#guide)
 
 ### Basic hNhM concepts
@@ -93,4 +94,7 @@ The physical result of applied changes:
 
 <img src="assets/quick_start_result.png" height="150px">
 
+## DWH example
+Full DWH example including Entities, Links and Flows can be found in the [`dwh/`](dwh/) directory.
+
 ## Guide

dwh/flows.py

@@ -0,0 +1,30 @@
+from hnhm import Flow
+
+from .user import User
+from .review import Review
+from .amazon_stage import AmazonStg
+from .user_review import LinkUserReview
+
+flow = (
+    Flow(source=AmazonStg(), business_time_field=AmazonStg.time)
+    .load(
+        User(),
+        mapping={
+            User.user_id: AmazonStg.user_id,
+            User.name: AmazonStg.name,
+        },
+    )
+    .load(
+        Review(),
+        mapping={
+            Review.review_id: AmazonStg.review_id,
+            Review.user_id: AmazonStg.user_id,
+            Review.text: AmazonStg.text,
+            Review.rating: AmazonStg.rating,
+        },
+    )
+    .load(LinkUserReview())
+)
+
+if __name__ == "__main__":
+    print(flow.tasks)

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "hnhm"
-version = "0.0.3"
+version = "0.0.4"
 description = "hNhM – highly Normalized hybrid Model."
 authors = ["Arseny Egorov <[email protected]>"]