python - pycurl subprocess in a separate Thread -

-

i need output pycurl, i'm trying run in subprocess. output i'm trying put in queue , pull queue out in different class.

unfortunately, right have no output =(

import threading import random import time import queue import urllib2 import sys import simplejson, pycurl import sys, signal  queue = queue.queue() keep_running = true user = "username" pswd = "pass"  class mythread(threading.thread):     def __init__(self, queue):         threading.thread.__init__(self)         self.queue = queue      def run(self):         curl_path = '/usr/bin/curl'         curl_list = [curl_path]         args = ('curl', 'https://stream.twitter.com/1/statuses/filter.json?track=java', '-u', 'user:pass')         arg in args:             curl_list.append(arg)             child = subprocess.popen(                          curl_list,                          shell=false,                          #stdout=subprocess.pipe)                          stderr=subprocess.pipe)             try:                 out += child.communicate()                 c_out.write(out)                 self.queue.put(c_out)                 self.queue.task_done()             except keyboardinterrupt:                 child.kill()   class starter():     def __init__(self):         self.queue = queue         t = mythread(self.queue)         t.daemon=true         t.start()         self.next()      def next(self):         while true:             time.sleep(0.5)             if not self.queue.empty():                 line = self.queue.get(timeout=0.2)                 print '\n\nim in starter %s' % line             else:                 print 'waiting queue'  def main():       try:         starter()          except keyboardinterrupt, e:         print 'stopping'         raise  main()

you seem confusing arguments subprocess quite bit... args list should of different pieces of command using curl, putting them in fashion not going work subprocess. curl_list should more this...

curl_path = '/usr/bin/curl' curl_list = [curl_path, 'https://stream.twitter.com/1/statuses/filter.json?track=java', '-u', 'user:pass']

you using unnecessary @ moment... don't want loop on list want pass subprocess handle appropriately. , going want stdout results that, need include pipe there well.

i.e, entire thing should be...

def run(self):     curl_path = '/usr/bin/curl'     curl_list = [curl_path, 'https://stream.twitter.com/1/statuses/filter.json?track=java', '-u', 'user:pass']      child = subprocess.popen(curl_list,                              shell=false,                              stdout=subprocess.pipe,                              stderr=subprocess.pipe)     try:         out += child.communicate()[0]         c_out.write(out)         self.queue.put(c_out)         self.queue.task_done()         except keyboardinterrupt:             child.kill()

might want take @ subprocess documentation better understand changes above. haven't run through interpreter may not perfect should going in right direction... luck!


Popular posts from this blog

Php - Delimiter must not be alphanumeric or backslash -

-
this question has answer here: delimiter must not alphanumeric or backslash , preg_match 5 answers this question has been asked don't know how fix problem in situation. getting following php errror: php message: php warning: preg_match(): delimiter must not alphanumeric or backslash in... on line 227 line 227 following: if (preg_match($match, $_server['http_user_agent'])) and function: $oslist = array ( 'windows 3.11' => 'win16', 'windows 95' => '(windows 95)|(win95)|(windows_95)', 'windows 98' => '(windows 98)|(win98)', 'windows 2000' => '(windows nt 5.0)|(windows 2000)', 'windows xp' => '(windows nt 5.1)|(windows xp)', 'windows server 2003' => '(windows nt 5.2)', 'windows vista' => '(windows nt 6.0)', 'w...
Read more

Delphi interface implements -

-
i expect reference counting should work on outer aggregating object in interface implementation. if can refer example: clarity in classes implementing multiple interfaces (alternative delegation): here minimal reproduction of behaviour: program so16210993; {$apptype console} type ifoo = interface procedure foo; end; tfooimpl = class(tinterfacedobject, ifoo) procedure foo; end; tcontainer = class(tinterfacedobject, ifoo) private ffoo: ifoo; public constructor create; destructor destroy; override; property foo: ifoo read ffoo implements ifoo; end; procedure tfooimpl.foo; begin writeln('tfooimpl.foo called'); end; constructor tcontainer.create; begin inherited; ffoo := tfooimpl.create; end; destructor tcontainer.destroy; begin writeln('tcontainer.destroy called');//this line never runs inherited; end; procedure main; var foo : ifoo; begin foo := tcontainer.create; foo.foo; end; begin main; readln...
Read more

java - How to create Table using Apache PDFBox -

-
java - How to create Table using Apache PDFBox - we planning migrate our pdf generation utilities itext pdfbox (due licensing issues in itext). effort, able write , position text, draw lines etc. creating tables text embedded in table cells challenge, went through documentation, examples, google, stackoverflow couldn't find thing. wondering if pdfbox provides native back upwards creating tables embedded text. lastly resort utilize link https://github.com/eduardohl/paginated-pdfbox-table-sample thanks links provided tilman. using boxable api ( https://github.com/dhorions/boxable ) able create table wanted to. fyi wanted create table variable number of cells. illustration row 1 have 2 cells, row 2 have 5 cells , row 3 have 3 cells. able ease. followed example1.java in link mentioned above. java pdf pdfbox
Read more