move demo.py to examples/

Author: BugenZhao

README.md

@@ -2,6 +2,7 @@
 
 Simple Python SDK for event-driven applications with RisingWave.
 
+
 ## Quick start
 
 ### 1. Install risingwave-py ([PyPI](https://pypi.org/project/risingwave-py/))
@@ -27,7 +28,7 @@ You can also provision a free-tier cluster in [RisingWave Cloud](https://cloud.r
 ### 3. Interact with RisingWave in Python
 #### Initialization
 ```python
-from risingwave import RisingWave, RisingWaveConnOptions, OutputFormat
+from src.risingwave import RisingWave, RisingWaveConnOptions, OutputFormat
 import pandas as pd
 import threading
 
@@ -124,6 +125,11 @@ rw.insert(table_name="test_product", data=test_df3)
 
 ## Demo
 You can also check the demo in our [repo](https://github.com/risingwavelabs/risingwave-py).
+
 ```shell
-uv run demo.py simple
+# Run the simple demo
+uv run examples/demo.py simple
+
+# Run the Binance demo
+uv run examples/demo.py boll
 ```

examples/__init__.py

@@ -0,0 +1 @@
+# This file is intentionally left empty to make the directory a Python package

binance/__init__.py renamed to examples/binance/__init__.py

@@ -111,7 +111,8 @@ def subscribe_tick_analytics():
 
 
 def demo_boll():
-    import binance
+    # Import from the examples package
+    from examples.binance import subscribe_bars
 
     from datetime import datetime
     from risingwave import RisingWave
@@ -152,7 +153,7 @@ def handle_binance_klines_update(data):
         )
 
     def subscribe_binance():
-        binance.subscribe_bars(
+        subscribe_bars(
             streams=["ethusdt@kline_1m", "ethusdt@kline_5m", "ethusdt@kline_15m"],
             handler=handle_binance_klines_update,
         )

binance/core.py renamed to examples/binance/core.py

@@ -3,7 +3,7 @@ requires = ["hatchling"]
 build-backend = "hatchling.build"
 
 [tool.hatch.build.targets.sdist]
-exclude = ["/.git", "/venv", "/.venv", "/binance"]
+exclude = ["/.git", "/venv", "/.venv", "/examples"]
 
 
 [tool.hatch.build.targets.wheel]