move the collectdconsole thing into examples/

Author: zzzeek

examples/helloworld/README.rst

@@ -0,0 +1,50 @@
+====================
+Hello World Example
+====================
+
+A minimal example to see sqlalchemy-collectd do something.
+
+
+Step One - Run collectd as a console app
+========================================
+
+In one terminal window, run collectd as an interactive application with
+the -f flag::
+
+	# cd examples/helloworld
+	# collectd -f -C collectdconsole.conf
+
+The ``collectdconsole.conf`` includes a relative path to the
+sqlalchemy-collectd checkout as the module path.
+
+Step Two - Run the demo program
+================================
+
+This program uses a SQLite database for starters.    It spins up
+five processes with 20 threads each::
+
+	# python run_queries.py
+
+Step Three - watch collectd console
+===================================
+
+Output looks something like::
+
+	$ collectd -f -C collectdconsole.conf
+	[2018-02-11 18:29:35] plugin_load: plugin "logfile" successfully loaded.
+	[2018-02-11 18:29:35] [info] plugin_load: plugin "write_log" successfully loaded.
+	[2018-02-11 18:29:35] [info] plugin_load: plugin "python" successfully loaded.
+	[2018-02-11 18:29:35] [info] sqlalchemy_collectd plugin version 0.0.1
+	[2018-02-11 18:29:35] [info] Python version: 3.6.4 (default, Jan 23 2018, 22:28:37)
+	[GCC 7.2.1 20170915 (Red Hat 7.2.1-2)]
+	[2018-02-11 18:29:35] [info] Initialization complete, entering read-loop.
+	[2018-02-11 18:29:45] [info] write_log values:
+	[{"values":[0],"dstypes":["gauge"],"dsnames":["value"],"time":1518391784.793,"interval":10.000,"host":"photon2","plugin":"sqlalchemy","plugin_instance":"run_queries.py","type":"count","type_instance":"checkedin"}]
+	[2018-02-11 18:29:45] [info] write_log values:
+	[{"values":[0],"dstypes":["gauge"],"dsnames":["value"],"time":1518391784.793,"interval":10.000,"host":"photon2","plugin":"sqlalchemy","plugin_instance":"run_queries.py","type":"count","type_instance":"detached"}]
+	[2018-02-11 18:29:45] [info] write_log values:
+	[{"values":[6],"dstypes":["gauge"],"dsnames":["value"],"time":1518391784.793,"interval":10.000,"host":"photon2","plugin":"sqlalchemy","plugin_instance":"run_queries.py","type":"count","type_instance":"numprocs"}]
+	[2018-02-11 18:29:45] [info] write_log values:
+	[{"values":[6],"dstypes":["gauge"],"dsnames":["value"],"time":1518391784.793,"interval":10.000,"host":"photon2","plugin":"sqlalchemy","plugin_instance":"run_queries.py","type":"count","type_instance":"numpools"}]
+	[2018-02-11 18:29:45] [info] write_log values:
+	[{"values":[28],"dstypes":["gauge"],"dsnames":["value"],"time":1518391784.793,"interval":10.000,"host":"photon2","plugin":"sqlalchemy","plugin_instance":"host","type":"count","type_instance":"checkedout"}]

collectdconsole.conf renamed to examples/helloworld/collectdconsole.conf

@@ -19,12 +19,9 @@ LoadPlugin write_log
 
 LoadPlugin python
 <Plugin python>
-    ModulePath "/home/classic/dev/sqlalchemy-collectd"
+    ModulePath "../../"
     LogTraces true
 
-</Plugin>
-
-<Plugin python>
     Import "sqlalchemy_collectd.server.plugin"
 
     <Module "sqlalchemy_collectd.server.plugin">
@@ -36,25 +33,3 @@ LoadPlugin python
 </Plugin>
 
 
-LoadPlugin write_graphite
-
-<Plugin write_graphite>
-    <Node "local">
-    Host localhost
-    Port "2003"
-    Protocol "tcp"
-    ReconnectInterval 0
-    LogSendErrors true
-    Prefix "collectd."
-    #Postfix "collectd"
-    StoreRates true
-    AlwaysAppendDS false
-    EscapeCharacter "_"
-    SeparateInstances false
-    PreserveSeparator false
-    DropDuplicateFields false
-    </Node>
-</Plugin>
-
-#LoadPlugin interface
-#LoadPlugin cpu

examples/helloworld/file.db

@@ -0,0 +1,44 @@
+from sqlalchemy import create_engine
+import random
+import time
+import threading
+import multiprocessing
+
+import logging
+logging.basicConfig()
+logging.getLogger("sqlalchemy_collectd").setLevel(logging.DEBUG)
+
+e = create_engine("sqlite:///file.db?plugin=collectd")
+
+
+def worker():
+    e.dispose()
+
+    def screw_w_pool():
+        while True:
+            conn = e.connect()
+            try:
+                time.sleep(random.random())
+                conn.execute("select 1")
+                time.sleep(random.random())
+            finally:
+                conn.close()
+            time.sleep(random.randint(1, 5))
+
+    threads = [threading.Thread(target=screw_w_pool) for i in range(20)]
+    for t in threads:
+        t.daemon = True
+        t.start()
+
+    while True:
+        time.sleep(1)
+
+
+procs = [multiprocessing.Process(target=worker) for i in range(5)]
+for proc in procs:
+    time.sleep(.5)
+    proc.daemon = True
+    proc.start()
+
+while True:
+    time.sleep(1)