Как использовать приложение Flask с BaleBot для отправки сообщения пользователям - PullRequest
Новая
       25

Как использовать приложение Flask с BaleBot для отправки сообщения пользователям

0 голосов
/ 24 июня 2018

Я хочу использовать приложение Flask для получения запроса на отправку сообщения пользователям Bale.

этот код работает! BaleBot ответит на сообщение пользователя и ответ приложения Flask но bot.send_message в def send_to_user не работает!

например, если я отправлю сообщение (любую вещь) в Bale моему боту, его ответ. и если я отправлю запрос в Flask, например curl -X POST 127.0.0.1:5000/send/user -d 'bale_id=1533910422&access_hash=6644828719985087310&message=text', Flask ответит. 

import os

import asyncio
from flask import Flask
from flask import request
from balebot.handlers import *
from balebot.filters import *
from balebot.models.base_models import Peer
from balebot.models.messages import *
from balebot.updater import Updater
from balebot.config import Config
from threading import Thread

import zbxbale_settings

Config.log_level = zbxbale_settings.LOG_LEVEL

updater = Updater(token=zbxbale_settings.bale_key, loop=asyncio.get_event_loop())
# updater = Updater(token=zbxbale_settings.bale_key)
dispatcher = updater.dispatcher
bale_bot = updater.bot


def success(result, err):
    print("success : ", result)
    print("success : ", err)


def failure(result, err):
    print("failure : ", result)


@dispatcher.command_handler("/start")
def start_command(bot, update):
    message = update.get_effective_message()
    bot.respond(update, message, success_callback=success, failure_callback=failure)


@dispatcher.default_handler()
def default_handler(bot, update):
    message = update.get_effective_message()
    message.text += " not recognized"
    bot.respond(update, message, success_callback=success, failure_callback=failure)


app = Flask(__name__)


@app.route("/")
def hello():
    return "Hello"


@app.route("/send/user", methods=['POST'])
def send_to_user():
    bale_id = request.form['bale_id']
    access_hash = request.form['access_hash']
    message = request.form['message']
    p = Peer('User', bale_id, access_hash)
    m = TextMessage(message)
    bale_bot.send_message(m, p, success_callback=success, failure_callback=failure)
    return "Hello World!"


@app.route("/send/group", methods=['POST'])
def send_to_group():
    bale_id = request.form['bale_id']
    access_hash = request.form['access_hash']
    return "Hello World!"


from multiprocessing import Process


p = Process(target=app.run, args=())
q = Process(target=updater.run, args=())

q.start()
p.start()
# q.join()
# p.join()
# app.run()
# updater.run()

p = Peer('User', "1533910422", "6644828719985087310")
m = TextMessage("salam")
updater.bot.send_message(m, p, success_callback=success, failure_callback=failure)

Ответы [ 2 ]

0 голосов
/ 25 июня 2018

с помощью @ ehsan-barkhordar этот код написан и это правильно: 

import pykka

import asyncio
from flask import Flask
from flask import request
from balebot.handlers import *
from balebot.filters import *
from balebot.models.base_models import Peer
from balebot.models.messages import *
from balebot.updater import Updater

updater = Updater(token="token", loop=asyncio.get_event_loop())
dispatcher = updater.dispatcher
bale_bot = updater.bot


def success(result, err):
    print("success : ", result)
    print("success : ", err)


def failure(result, err):
    print("failure : ", result)


@dispatcher.command_handler("/start")
def start_command(bot, update):
    message = update.get_effective_message()
    bot.respond(update, message, success_callback=success, failure_callback=failure)


app = Flask(__name__)


class ServerActor(pykka.ThreadingActor):
    def __init__(self, flask_app):
        super(ServerActor, self).__init__()
        self.flask_app = flask_app

    def on_receive(self, message):
        print(message)

    def run(self):
        self.flask_app.run(host='0.0.0.0', port=5050)

    def shutdown_server(self):
        func = request.environ.get('werkzeug.server.shutdown')
        if func is None:
            raise RuntimeError('Not running with the Werkzeug Server')
        func()


@app.route("/", methods=['GET'])
def send_to_user():
    message = "hello"
    m = TextMessage(message)
    bale_bot.send_message(m, Peer('User', "1533910422", "6644828719985087310"), success_callback=success,
                          failure_callback=failure)
    return "message sent"


# class SMStarter():
def start(notification_sender, server_actor_ref):
    server_proxy = server_actor_ref.proxy()
    future = server_proxy.run()
    notification_sender.run()
    notification_sender.stop()


start(notification_sender=updater, server_actor_ref=ServerActor.start(flask_app=app))
0 голосов
/ 24 июня 2018

Обычно у вас есть два варианта. Во-первых, используя общую базу данных между двумя программами, одна получает запросы и записывает в базу данных, а другая читает базу данных и отправляет сообщения. Во-вторых, вы бы использовали актер в Pykka, если вы не хотите использовать базу данных. Он реализует акторы в Thread и использует их для отправки сообщения при получении запроса. вот хороший документ об этом: https://www.pykka.org/en/latest/

...