Как передать метаданные Twitter в клиентский браузер с сервера в Python/flask

Я пытаюсь вернуть клиенту поток метаданных Twitter, которые клиент вводит в форме, отфильтрованной по «дорожке» tweepy.

У меня проблема в том, что обратно в браузер ничего не возвращается, хотя сервер его получает и обрабатывает запрос. Это мой код до сих пор:

Основной.ру:

import flask
from flask.views import MethodView
from tweetStreamsRT import StreamerRt


app = flask.Flask(__name__)
app.secret_key = "asecret"

class View(MethodView):

def get(self):
    return flask.render_template('index.html')

def post(self):
    results = StreamerRt().filter(track = (flask.request.form['event']))
    flask.flash(results)
    return self.get()

 app.add_url_rule('/', view_func = View.as_view('index'), methods=['GET', 'POST'])
 app.debug = True
 app.run()

Класс, подключающийся к Twitter Streaming API:

import sys
import tweepy
import json
import time
#from textwrap import TextWrapper
import pymongo

CONSUMER_KEY = ''
CONSUMER_SECRET = ''

ACCESS_TOKEN = ''
ACCESS_TOKEN_SECRET = ''

auth = tweepy.OAuthHandler(CONSUMER_KEY,CONSUMER_SECRET)
auth.set_access_token(ACCESS_TOKEN,ACCESS_TOKEN_SECRET)


connection = pymongo.Connection()  
db = connection.twitterStream

class Listener(tweepy.StreamListener):


    def on_status(self, status):
        message = {}

        if status.author.lang == 'en':
            try:
                message = {
                           'Author': status.author.screen_name,
                           'Author_id': status.id,
                           'Time_normal': str(status.created_at),
                           'geo_enabled': status.author.geo_enabled,
                           'Geo': status.geo,
                           'Place' : status.place,
                           'Coordinates': status.coordinates}

                db.tweetStream.insert(message)


            except Exception, e:
                print >> sys.stderr, 'Encountered Exception:', e
                pass

        def on_error(self, status_code):

            waitPeriod = 60
            if status_code == 420:
                print >> sys.stderr, 'Encountered a %i Error, will retry in %i minutes'     % \
                (status_code, waitPeriod/60)
                time.sleep(waitPeriod)
                waitPeriod *= 2
                return waitPeriod
            else:            
                print >> sys.stderr, 'Encountered error with status code:', status_code
                return True 

        def on_timeout(self):
            print >> sys.stderr, 'Timeout...'
            return True 

def StreamerRt():
    return tweepy.streaming.Stream(auth, Listener(), timeout=60)

Мой html-файл, который наследуется от базы и формирует html-файл:

{% extends "base.html" %}
{% import "forms.html" as forms %}


{% block page_header %}
  <div class="page-header">
    <h1>Welcome</h1>
  </div>
{% endblock %}
{% block content %}
  <h2>Enter the Event you would like to follow</h2>
      <form action="/" method="post">
            <input type="text" name="event" />
            <input type="submit" value="Submit Query" />
          </form>
        {% with messages = get_flashed_messages() %}
    {% if messages %}
                Results:
                <pre>
                    {% for message in messages %}
{{ message }}
                    {% endfor %}
                  </pre>
               {% endif %}
             {% endwith %}        
           {% endblock %}

Кажется, я не могу вернуть какие-либо потоковые данные клиенту.

Как вы могли вернуть определенные метаданные из Twitter Streaming API в браузер, в то же время, когда они записываются в БД.

Спасибо

Кроме того, функция StreamerRt не фильтрует по дорожке как ввод от клиента, но, кажется, возвращает всю общедоступную временную шкалу.


person user94628    schedule 18.10.2012    source источник


Ответы (1)


Я думаю, что Flask-Sijax — это то, что вам нужно. Hookbox — еще один вариант, здесь — руководство о том, как интегрировать hookbox с flask. Еще один вариант: gevent здесь — это сообщение SO об использовании gevent с флягой. Последнее, что я могу вспомнить, это tornado.

person John    schedule 23.10.2012
comment
Спасибо, я пытаюсь сделать это, используя juggernaut из примера фрагмента фляги: stackoverflow.com/questions/13038376/ Клиенту все равно ничего не отправляется# - person user94628; 24.10.2012