在一個單獨的線程中的pycurl子進程

Question

我需要幫助來從pycurl獲取輸出，我試圖在子進程中運行。我試圖把這個輸出放入一個隊列中，而不是把這個隊列放在另一個類中。

不幸的是，現在我有沒有輸出=（

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') 
     for 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 for queue' 

def main(): 
    try: 
     Starter()  
    except KeyboardInterrupt, e: 
     print 'Stopping' 
     raise 

main() 

Answer 1

你似乎混淆你的參數子過程很有點...的的args列表應該是所有不同的部分命令的那你會使用捲曲，你正在把它們都聚集在這是不會與子工作的方式。你應該curl_list看起來更像這個...

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

您同時還使用了不必要的此刻......你不想在這個列表中循環你只是想將它傳遞給子進程，這將適當地處理它。而且你也希望stdout從中得到結果，所以你也需要在其中包含管道。

即，整個事情應該是...

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() 

可能要考慮再看看subprocess documentation更好地理解上述的變化。我實際上並沒有通過口譯員來解決這個問題，所以它可能並不完美，但應該讓你朝着正確的方向前進......祝你好運！