Skip to content

Commit 97d9870

Browse files
feat: add stagingquery quickstart for purchases
Co-authored-by: Thomas Chow <[email protected]>
1 parent 2010a0b commit 97d9870

File tree

1 file changed

+23
-0
lines changed

1 file changed

+23
-0
lines changed

api/py/test/sample/group_bys/quickstart/purchases.py

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
from ai.chronon.api.ttypes import Source, EventSource
1616
from ai.chronon.query import Query, select
1717
from ai.chronon.group_by import GroupBy, Aggregation, Operation
18+
from ai.chronon.api.ttypes import StagingQuery, MetaData
1819

1920
"""
2021
This GroupBy aggregates metrics about a user's previous purchases in various windows.
@@ -67,3 +68,25 @@
6768
),
6869
],
6970
)
71+
72+
73+
query = """
74+
SELECT
75+
ts,
76+
ds,
77+
purchase_id,
78+
user_id,
79+
product_id,
80+
purchase_price
81+
FROM data.purchases
82+
WHERE ds BETWEEN '{{ start_date }}' AND '{{ end_date }}'
83+
"""
84+
85+
staging_query = StagingQuery(
86+
query=query,
87+
startPartition="2023-10-31",
88+
metaData=MetaData(
89+
name='purchases_staging_query',
90+
outputNamespace="data"
91+
)
92+
)

0 commit comments

Comments
 (0)