[python] add multi condition tutorial

ChunelFeng · ChunelFeng · commit 2476338ae404 · 2025-03-08T00:21:53.000+08:00
diff --git a/COMPILE.md b/COMPILE.md
@@ -50,5 +50,13 @@
   ```shell
   $ sudo apt-get install cmake -y           # 安装cmake
   $ ./CGraph-build.sh                       # 编译CGraph工程，生成的内容在同级/build/文件夹中
-  $ ./build/tutorial/T00-HelloCGraph        # 运 行T00-HelloCGraph，并且在终端输出 Hello, CGraph.
+  $ ./build/tutorial/T00-HelloCGraph        # 运行T00-HelloCGraph，并且在终端输出 Hello, CGraph.
+  ```
+
+* 安装PyCGraph，使用前需要提前安装`python3` `pybind11`和`setuptools`
+  ```shell
+  $ git clone https://github.com/ChunelFeng/CGraph.git
+  $ cd CGraph/python                       # 进入对应文件夹
+  $ python3 setup.py install               # 安装 PyCGraph
+  $ python3 tutorial/T00-HelloCGraph.py    # 运行T00-HelloCGraph.py，并且在终端输出 Hello, PyCGraph.
   ```
diff --git a/python/CMakeLists.txt b/python/CMakeLists.txt
diff --git a/python/setup.py b/python/setup.py
@@ -1,28 +1,36 @@
-#!/usr/bin/env python
-# -*- coding: UTF-8 -*-
+"""
+@Author: Chunel
+@Contact: chunel@foxmail.com
+@File: setup
+@Time: 2025/3/6 23:25
+@Desc:
+"""
 
 import glob
 from setuptools import setup, Extension
 import pybind11
 
-sources = ['PyCGraph.cpp'] + glob.glob("../src/**/*.cpp", recursive=True)
-extra_compile_args = ["-pthread", "-std=c++11", '-fvisibility=hidden']
-include_dirs = [pybind11.get_include(), "../src"]
+_sources = ['PyCGraph.cpp'] + glob.glob("../src/**/*.cpp", recursive=True)
+_extra_compile_args = ["-pthread", "-std=c++11", '-fvisibility=hidden']
+_include_dirs = [pybind11.get_include(), "../src"]
 
 ext_modules = [
     Extension(
         name = "PyCGraph",
-        sources = sources,
-        extra_compile_args = extra_compile_args,
-        include_dirs = include_dirs,
+        sources = _sources,
+        extra_compile_args = _extra_compile_args,
+        include_dirs = _include_dirs,
     ),
 ]
 
 setup(
-    name="PyCGraph",
-    version="0.0.1",
-    author="Chunel Feng",
-    description="CGraph with python API",
-    ext_modules=ext_modules,
-    zip_safe=False,
+    name = "PyCGraph",
+    version = "1.0.0",
+    author = "Chunel Feng",
+    author_email = "chunel@foxmail.com",
+    description = "CGraph with python api wrapper by pybind11",
+    url = "https://github.com/ChunelFeng/CGraph",
+    license = "Apache-2.0",
+    ext_modules = ext_modules,
+    zip_safe = False,
 )
diff --git a/python/tutorial/MyGNode/HelloCGraphNode.py b/python/tutorial/MyGNode/HelloCGraphNode.py
@@ -10,5 +10,5 @@
 
 class HelloCGraphNode(GNode):
     def run(self):
-        print("Hello PyCGraph")
+        print("Hello, PyCGraph.")
         return CStatus()
diff --git a/python/tutorial/MyGNode/MyHoldNode.py b/python/tutorial/MyGNode/MyHoldNode.py
@@ -11,17 +11,17 @@
 from MyParams.MyParam import MyParam
 
 class MyHoldNode(GNode):
-    param_key = 'hold-param'
+    _param_key = 'hold-param'
     def init(self):
-        return self.createGParam(MyParam(), self.param_key)
+        return self.createGParam(MyParam(), self._param_key)
 
     def run(self):
-        param: MyParam = self.getGParam(self.param_key)
+        param: MyParam = self.getGParam(self._param_key)
         param.value += 1
         print('current value is {0}'.format(param.value))
         return CStatus()
 
     def isHold(self):
-        param: MyParam = self.getGParam(self.param_key)
+        param: MyParam = self.getGParam(self._param_key)
         print('enter hold path, value is {0}'.format(param.value))
         return param.value < 5
diff --git a/python/tutorial/MyGNode/MyMatchNode.py b/python/tutorial/MyGNode/MyMatchNode.py
@@ -0,0 +1,31 @@
+"""
+@Author: Chunel
+@Contact: chunel@foxmail.com
+@File: MyMatchNode
+@Time: 2025/3/7 23:54
+@Desc: 
+"""
+
+import time
+from datetime import datetime
+
+from PyCGraph import GNode, CStatus
+
+from MyParams.MyParam import MyParam
+
+
+class MyMatchNode(GNode):
+    def run(self):
+        time.sleep(1)
+        print("[{0}] run MyMatchNode: {1}".format(datetime.now(), self.getName()))
+
+        return CStatus()
+
+    def isMatch(self):
+        param: MyParam = self.getGParamWithNoEmpty('param1')
+        result = 0 != param.count % 2
+        if result:
+            print('    match, ready to run {0}'.format(self.getName()))
+        else:
+            print('    not match, will not run {0}'.format(self.getName()))
+        return result
diff --git a/python/tutorial/T21-MultiCondition.py b/python/tutorial/T21-MultiCondition.py
@@ -0,0 +1,31 @@
+"""
+@Author: Chunel
+@Contact: chunel@foxmail.com
+@File: T21-MultiCondition
+@Time: 2025/3/7 23:52
+@Desc: 
+"""
+
+from PyCGraph import GPipeline, GSerialMultiCondition, GParallelMultiCondition
+
+from MyGNode.MyMatchNode import MyMatchNode
+from MyGNode.MyNode1 import MyNode1
+from MyGNode.MyWriteParamNode import MyWriteParamNode
+
+
+def tutorial_multi_condition():
+    a, c = MyWriteParamNode(), MyWriteParamNode()
+    b_multi_condition = GSerialMultiCondition([MyNode1('nodeB1'), MyMatchNode('nodeB2')])
+    d_multi_condition = GParallelMultiCondition([MyMatchNode('nodeD1'), MyMatchNode('nodeD2')])
+
+    pipeline = GPipeline()
+    pipeline.registerGElement(a, set(), 'nodeA')
+    pipeline.registerGElement(b_multi_condition, {a}, 'multiConditionB')
+    pipeline.registerGElement(c, {b_multi_condition}, 'nodeC')
+    pipeline.registerGElement(d_multi_condition, {c}, 'multiConditionD')
+
+    pipeline.process()
+
+
+if __name__ == '__main__':
+    tutorial_multi_condition()
