telegram bot 一直在回复而不是执行以下代码(使用了 webhook)

telegram bot keeps replying rather than executing the following code (webhook is used)

我正在尝试在 GAE 上为多人游戏托管我的电报机器人,这里使用了网络挂钩。这就是我的数据库部分的样子:

class Game(ndb.Model):
    chat_id = ndb.IntegerProperty(required = True)
    mission_num = ndb.IntegerProperty(default =1)
    round_num = ndb.IntegerProperty(default =1)

class Player(ndb.Model):
    user_id = ndb.IntegerProperty(required=True)
    player_role = ndb.StringProperty (
    choices = ['spy','resistance'])

web hook handler下的部分代码:

        if text.startswith('/'):
        if text == '/start':
            reply('Bot enabled')
            setEnabled(chat_id, True)
        elif text == '/stop':
            reply('Bot disabled')
            setEnabled(chat_id, False)
        elif text == '/newgame':
            if chat_type == 'group':
                existing_game = Game.query (Game.chat_id == chat_id).get()
                if existing_game:
                    reply ("game is alr intitiated liao")
                else:
                    ##create a new game here 
                    #still stuck here 
                    ##========================##
                    #reply("keep replying this line")
                    ##========================##
                    new_game = Game (
                        chat_id = chat_id,
                        id = chat_id
                        )    
                    curr_game_key = new_game.put()

                    new_player = Player (
                        parent = curr_game_key,
                        user_id = fr_user_id,
                        id = fr_user_id)
                    new_player.put()
                    reply("waiting for more friends to join")
            else:
                reply('game must be conducted within a group chat! jio more friends!')
        else:
            reply('What command?')
    else:
        if getEnabled(chat_id):
            reply('I got your message! (but I do not know how to answer)')
        else:
            logging.info('not enabled for chat_id {}'.format(chat_id))

问题是,当我在群聊中发送“/newgame”时,没有任何内容返回给我。如果我取消注释以下行,我的机器人会疯狂地向我发送 "keep replying this line"。:

#reply("keep replying this line")

回复功能:

def reply(msg=None, img=None):
        if msg:
            resp = urllib2.urlopen(BASE_URL + 'sendMessage', urllib.urlencode({
                'chat_id': str(chat_id),
                'text': msg.encode('utf-8'),
                'disable_web_page_preview': 'true',
                'reply_to_message_id': str(message_id),
            })).read()
        elif img:
            resp = multipart.post_multipart(BASE_URL + 'sendPhoto', [
                ('chat_id', str(chat_id)),
                ('reply_to_message_id', str(message_id)),
            ], [
                ('photo', 'image.jpg', img),
            ])
        else:
            logging.error('no msg or img specified')
            resp = None

        logging.info('send response:')
        logging.info(resp)

错误:

Internal Server Error
The server has either erred or is incapable of performing the requested operation.

Traceback (most recent call last):
  File "/base/data/home/runtimes/python27/python27_lib/versions/third_party/webapp2-2.5.2/webapp2.py", line 1535, in __call__
    rv = self.handle_exception(request, response, e)
  File "/base/data/home/runtimes/python27/python27_lib/versions/third_party/webapp2-2.5.2/webapp2.py", line 1529, in __call__
    rv = self.router.dispatch(request, response)
  File "/base/data/home/runtimes/python27/python27_lib/versions/third_party/webapp2-2.5.2/webapp2.py", line 1278, in default_dispatcher
    return route.handler_adapter(request, response)
  File "/base/data/home/runtimes/python27/python27_lib/versions/third_party/webapp2-2.5.2/webapp2.py", line 1102, in __call__
    return handler.dispatch()
  File "/base/data/home/runtimes/python27/python27_lib/versions/third_party/webapp2-2.5.2/webapp2.py", line 572, in dispatch
    return self.handle_exception(e, self.app.debug)
  File "/base/data/home/runtimes/python27/python27_lib/versions/third_party/webapp2-2.5.2/webapp2.py", line 570, in dispatch
    return method(*args, **kwargs)
  File "/base/data/home/apps/s~orbitaltest2/1.393734187774164753/main.py", line 66, in get
    self.response.write(json.dumps(json.load(urllib2.urlopen(BASE_URL + 'getUpdates'))))
  File "/base/data/home/runtimes/python27/python27_dist/lib/python2.7/urllib2.py", line 127, in urlopen
    return _opener.open(url, data, timeout)
  File "/base/data/home/runtimes/python27/python27_dist/lib/python2.7/urllib2.py", line 410, in open
    response = meth(req, response)
  File "/base/data/home/runtimes/python27/python27_dist/lib/python2.7/urllib2.py", line 523, in http_response
    'http', request, response, code, msg, hdrs)
  File "/base/data/home/runtimes/python27/python27_dist/lib/python2.7/urllib2.py", line 448, in error
    return self._call_chain(*args)
  File "/base/data/home/runtimes/python27/python27_dist/lib/python2.7/urllib2.py", line 382, in _call_chain
    result = func(*args)
  File "/base/data/home/runtimes/python27/python27_dist/lib/python2.7/urllib2.py", line 531, in http_error_default
    raise HTTPError(req.get_full_url(), code, msg, hdrs, fp)
HTTPError: HTTP Error 409: Conflict

第 66 行所属的处理程序代码:

class GetUpdatesHandler(webapp2.RequestHandler):
    def get(self):
        urlfetch.set_default_fetch_deadline(60)
        self.response.write(json.dumps(json.load(urllib2.urlopen(BASE_URL + 'getUpdates'))))

完全是新手,欢迎任何建议!

您应该检查您的 webhook return 编辑了哪些状态代码和哪些内容。

您有 2 个选项如何回复使用:

  1. 致电电报API
  2. Return JSON 作为对 webhook 调用的响应

由于您没有提供 reply() 的源代码,因此很难说出具体问题所在。

无论如何,您的 webhook 应该 return HTTP 状态代码 200。如果不是,Telegram 会将其视为内部错误并尝试向您重新发送消息。这就是为什么你会收到重复的电话,而且是 "replying like crazy"。

很可能调用 reply("keep replying this line") 是成功的,但后来出现了问题,Telegram 得到了错误的回复。

添加 try/except 块并记录异常。

检查您的日志并在需要时放置额外的日志记录。例如,我正在从我的 webhook 记录 HTTP 响应内容。有帮助。