Improve Python SDK

Signed-off-by: Zike Yang <[email protected]>

Author: RobertIndie

sdks/fs-python/Makefile

@@ -4,4 +4,4 @@ build-image:
 	docker build -t functionstream/fs-python-base .
 
 test:
-	pytest -v
+	PYTHONPATH=. python -m pytest

sdks/fs-python/README.md

@@ -24,23 +24,21 @@ FunctionStream SDK is a powerful Python library for building and deploying serve
 - **Message Processing**: Built-in support for Apache Pulsar message processing
 - **Metrics Collection**: Automatic collection of performance metrics
 - **Resource Management**: Efficient handling of connections and resources
-- **Graceful Shutdown**: Proper cleanup of resources during shutdown
 - **Configuration Management**: Flexible configuration through YAML files
-- **Schema Validation**: Input and output schema validation
 - **Error Handling**: Comprehensive error handling and logging
 
 ## Installation
 
 ```bash
-pip install fs-sdk
+pip install function-stream
 ```
 
 ## Quick Start
 
 1. Create a function that processes messages:
 
 ```python
-from fs_sdk import FSFunction
+from function_stream import FSFunction
 
 async def my_process_function(request_data: dict) -> dict:
     # Process the request data
@@ -180,13 +178,13 @@ source venv/bin/activate  # Linux/Mac
 pip install -r requirements.txt
 
 # Install the package in development mode
-pip install -e .
+python -m pip install -e .
 ```
 
 ### Running Tests
 
 ```bash
-pytest
+make test
 ```
 
 ## Support

sdks/fs-python/fs_sdk/__init__.py renamed to sdks/fs-python/function_stream/__init__.py

@@ -1,5 +1,5 @@
 from .function import FSFunction
 from .module import FSModule
 
-__version__ = "0.1.0"
+__version__ = "0.6.0rc1"
 __all__ = ["FSFunction", "FSModule"] 

sdks/fs-python/fs_sdk/config.py renamed to sdks/fs-python/function_stream/config.py

@@ -98,7 +98,7 @@ class Config(BaseModel):
     sink: Optional[SinkSpec] = None
     """Output sink configuration (optional)"""
 
-    subscriptionName: str = "fs-sdk-subscription"
+    subscriptionName: str = "function-stream-sdk-subscription"
     """Pulsar subscription name for consuming messages"""
 
     metric: Metric = Field(default_factory=Metric)

sdks/fs-python/fs_sdk/context.py renamed to sdks/fs-python/function_stream/context.py

@@ -3,8 +3,8 @@ testpaths = tests
 python_files = test_*.py
 python_classes = Test*
 python_functions = test_*
-asyncio_mode = auto
 log_cli = true
 log_cli_level = INFO
 log_cli_format = %(asctime)s [%(levelname)8s] %(message)s (%(filename)s:%(lineno)s)
-log_cli_date_format = %Y-%m-%d %H:%M:%S 
+log_cli_date_format = %Y-%m-%d %H:%M:%S
+asyncio_default_fixture_loop_scope = function 

sdks/fs-python/fs_sdk/function.py renamed to sdks/fs-python/function_stream/function.py

@@ -1,3 +1,4 @@
 pulsar-client>=3.0.0
+pyyaml>=6.0
 aiohttp>=3.8.0
 pydantic>=2.0.0