ecto example

Former-commit-id: ff6d7fd250

scripts/example_ecto_python.py

@@ -0,0 +1,35 @@
+import ecto
+import numpy as np
+class ClusterDetector(ecto.Cell):
+    def declare_params(self, params):
+        params.declare("n", "Max number of clusters.", 10)
+
+    def declare_io(self, params, inputs, outputs):
+        outputs.declare("clusters", "Clusters output. list of tuples", [])
+
+    def process(self, inputs, outputs):
+        clusters = []
+        for i in range(int(np.random.uniform(0, self.params.n))):
+            clusters.append( (i, 'c%d'%i) )
+        outputs.clusters = clusters
+
+class ClusterPrinter(ecto.Cell):
+    def declare_io(self, params, inputs, outputs):
+        inputs.declare("clusters", "Clusters input")
+
+    def process(self, inputs, outputs):
+        print "Clusters: ",
+        for c in inputs.clusters:
+            print c,
+        print "\n"
+
+def app():
+    cd = ClusterDetector(n=20)
+    cp = ClusterPrinter()
+    plasm = ecto.Plasm()
+    plasm.connect(cd['clusters'] >> cp['clusters'])
+    sched = ecto.Scheduler(plasm)
+    sched.execute(niter=3)
+
+if __name__ == "__main__":
+    app()