rjosephwright
rjosephwright
/ gist:6060201
Last active
December 20, 2015 02:59
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| _dispatch_queue = Queue() | |
| _queues = {} | |
| def get_queue(qname): | |
| return _queues[qname] | |
| def dispatcher(): | |
| while True: | |
| task = _dispatch_queue.get() | |
| if not task: break # "shutdown" happens by putting None on the queue, so it will break here |
rjosephwright
/ gist:6060335
Created
July 23, 2013 06:54
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| class Query(Task): | |
| @staticmethod | |
| def executor(qname): | |
| cx = sqlite3.connect(get_dbfile()) | |
| cx.row_factory = sqlite3.Row | |
| queue = get_queue(qname) | |
| while True: | |
| task = queue.get() | |
| for query, args in task.queries: | |
| result = cx.execute(query, args) |
rjosephwright
/ gist:6060371
Created
July 23, 2013 07:05
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| def start(): | |
| t = Thread(target=dispatcher) | |
| t.start() | |
| def shutdown(): | |
| _dispatch_queue.put(None) |
rjosephwright
/ gist:6060454
Last active
December 20, 2015 02:59
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| q = Query() | |
| q.add("UPDATE TRANSACTIONS SET STATUS=? WHERE ID=?", [new_status, id]) | |
| q.run() | |
| # To get a result, use get() | |
| result = q.get() | |
| # Or chain run() and get() | |
| result = q.run().get() |
rjosephwright
/ gist:6077013
Last active
December 20, 2015 05:19
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| def run_query(query, args): | |
| return Query().add(query, args).run() | |
| def run_queries(*queries): | |
| q = Query() | |
| for query, args in queries: q.add(query, args) | |
| return q.run() | |
| result = run_query("SELECT * FROM TRANSACTIONS WHERE ID=?", [id]) |
rjosephwright
/ gist:6077428
Last active
December 20, 2015 05:19
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| from functools import wraps | |
| class Function(Task): | |
| @staticmethod | |
| def executor(qname): | |
| queue = get_queue(qname) | |
| while True: | |
| task = queue.get() | |
| func, args, kwargs = task.funcspec | |
| task.put(func(*args, **kwargs)) |
rjosephwright
/ gist:6ef01870339ed6f3eab5
Created
July 22, 2014 23:42
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| --- WEB-MODE DEBUG BEG --- | |
| versions: emacs(24.3) web-mode("9.0.48") | |
| vars: engine(nil) content-type("") file("*scratch*") | |
| system: window(ns) config("x86_64-apple-darwin") | |
| colors: fg(nil) bg(nil) | |
| modes: whitespace-mode(nil) global-whitespace-mode(nil) rainbow-mode(nil) idle-highlight-mode(nil) fic-mode(nil) | |
| (transient-mark-mode line-number-mode column-number-mode auto-compression-mode auto-encryption-mode auto-composition-mode blink-cursor-mode font-lock-mode global-font-lock-mode file-name-shadow-mode mouse-wheel-mode tooltip-mode show-paren-mode auto-complete-mode global-auto-complete-mode global-rbenv-mode global-flycheck-mode) | |
| --- WEB-MODE DEBUG END --- | |
| File mode specification error: (wrong-type-argument number-or-marker-p nil) | |
| =: Wrong type argument: number-or-marker-p, nil |
rjosephwright
/ gist:9a0b76428ffa39bcdba2
Created
February 26, 2015 21:28
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| path: | |
| data: /var/lib/elasticsearch/data | |
| work: /var/lib/elasticsearch/work | |
| logs: /var/log/elasticsearch | |
| discovery: | |
| zen: | |
| ping: | |
| multicast: | |
| enabled: false | |
| tribe: |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| require 'json' | |
| require 'net/http' | |
| index_pattern = { | |
| 'index-pattern' => { | |
| 'properties' => { | |
| 'title' => { | |
| 'type' => 'string' | |
| }, | |
| 'timeFieldName' => { |
rjosephwright
/ packer log
Created
June 26, 2015 21:01
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 2015/06/26 13:49:26 [INFO] Packer version: 0.8.0 88e689faa22605759ee91c22bad9a5f463fcf78a+CHANGES | |
| 2015/06/26 13:49:26 Packer Target OS/Arch: linux amd64 | |
| 2015/06/26 13:49:26 Built with Go Version: go1.4.2 | |
| 2015/06/26 13:49:26 [DEBUG] Discovered plugin: amazon-chroot = /home/joswright/.local/packer-0.8.0/bin/packer-builder-amazon-chroot | |
| 2015/06/26 13:49:26 [DEBUG] Discovered plugin: amazon-ebs = /home/joswright/.local/packer-0.8.0/bin/packer-builder-amazon-ebs | |
| 2015/06/26 13:49:26 [DEBUG] Discovered plugin: amazon-instance = /home/joswright/.local/packer-0.8.0/bin/packer-builder-amazon-instance | |
| 2015/06/26 13:49:26 [DEBUG] Discovered plugin: digitalocean = /home/joswright/.local/packer-0.8.0/bin/packer-builder-digitalocean | |
| 2015/06/26 13:49:26 [DEBUG] Discovered plugin: docker = /home/joswright/.local/packer-0.8.0/bin/packer-builder-docker | |
| 2015/06/26 13:49:26 [DEBUG] Discovered plugin: file = /home/joswright/.local/packer-0.8.0/bin/packer-builder-file | |
| 2015/06/26 13:49:26 [DEBUG] Discovered plugin: googlecompute = |
OlderNewer