1

Task Queue と Channel API を理解しようとしています。

ユーザーがフォームを送信すると、60 秒以上実行されると予想されるプロセスがタスク キューに追加されます。このプロセスは、実行時にチャネル API を介してメッセージを送信する必要があります。粗雑なことに、私はこれを機能させることができないようです。SendMessagesHandlerクライアント側の JavaScript にメッセージを送信できない理由を誰か教えてもらえますか? それとも、クライアント側の JavaScript が正しく受信されていないのでしょうか? loggingまた、ログ コンソールからのメッセージは表示されません。ミルまたはSendMessagesHandlerの実行のみが表示されます。これを書いていると、ここで複数の問題が発生しているに違いないことに気づきました。タスクはタスク キューに作成されます。SDK コンソールで確認できますが、延々と実行され続けているように見えます。約1m2秒実行します。私が取り出したらINFO ... GETPOSTsleepそこからのコマンドSendMessageHandlerをすばやく実行して、SDK コンソールでキャッチすることさえできます。

よろしくお願いします。

main.py ファイルは次のとおりです。

#!/usr/bin/env python
import webapp2
import os
import jinja2
import logging
from time import sleep
from google.appengine.api import taskqueue, users, channel
from google.appengine.ext import db

class MainHandler(webapp2.RequestHandler):
    def get(self):
        user = users.get_current_user()
        if user:
            key = self.request.get('key')
            if not key:
                key = user.user_id()
            key_link = 'http://localhost:8080/?key=' + key
            token = channel.create_channel(key)
            template_values = {'token': token,
                    'me': user.user_id(),
                    'key': key,
                    'key_link': key_link,
                    'initial_message': 'Nothing to show yet'}
            template = jinja_environment.get_template('template.html')
            self.response.out.write(template.render(template_values))
        else:
            self.redirect(users.create_login_url(self.request.uri))

    def post(self):
        key = self.request.get('key')
        taskqueue.add(url='/sendmessages', params={'key': key})
        self.redirect('/')

class SendMessagesHandler(webapp2.RequestHandler):
    def post(self):
        key = self.request.get('key')
        sleep(2)
        channel.send_message(key, 'Starting to send messages...')
        logging.info('Starting to send messages...')
        i = 0
        while i < 60:
            i += 1
            logging.info('Counter incremented.')
            channel.send_message(key, 'Counter incemented.')
            sleep(1)

jinja_environment = jinja2.Environment(
        loader=jinja2.FileSystemLoader(os.path.dirname(__file__)))
app = webapp2.WSGIApplication([
        ('/', MainHandler),
        ('/sendmessages', SendMessagesHandler)
    ], debug=True)

ここにtemplate.htmlがあります

<html>
    <head>
        <title>Simple Task Queue Channel API</title>
        <script src='/_ah/channel/jsapi'></script>
    </head>
    <body>
        <script type='text/jacascript'>
            onOpened = function() {};
            onMessage = function(message) {
                var messageBox = document.getElementById("messageBox");
                messageBox.innerHTML = message;
            };
            onError = function() {};
            onClose = function() {};
            channel = new goog.appengine.Channel('{{token}}');
            socket = channel.open();
            socket.onopen = onOpened;
            socket.onmessage = onMessage;
            socket.onerror = onError;
            socket.onclose = onClose;
        </script>
        <form method="post" action="/">
            <input type="text" name="key" value="{{ key }}">
            <input type="submit" name="submit" value="Receive Messages">
        </form>
        <div id="messageBox"><!-- message should go in here --></div>
    </body>
</html>

ブラウザからのビュー ソースは次のとおりです。

<html>
<head>
    <title>Simple Task Queue Channel API</title>
    <script src='/_ah/channel/jsapi'></script>
</head>
<body>
    <script type='text/jacascript'>
        onOpened = function() {};
        onMessage = function(message) {
            var messageBox = document.getElementById("messageBox");
            messageBox.innerHTML = message;
        };
        onError = function() {};
        onClose = function() {};
        channel = new goog.appengine.Channel('channel-2840733866-1367208241-185804764220139124118');
        socket = channel.open();
        socket.onopen = onOpened;
        socket.onmessage = onMessage;
        socket.onerror = onError;
        socket.onclose = onClose;
    </script>
    <form method="post" action="/">
        <input type="text" name="key" value="185804764220139124118">
        <input type="submit" name="submit" value="Receive Messages">
    </form>
    <div id="messageBox"><!-- message should go in here --></div>
</body>
</html>
4

1 に答える 1

1

少なくとも 2 つのエラーを見つけました。

初め

<script type='text/javascript'>

2番

onMessage = function(message) {
        var messageBox = document.getElementById("messageBox");
        messageBox.innerHTML = message.data;
    };
于 2013-04-29T05:13:14.937 に答える