- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我想在 heroku 中制作一个应用程序,它将一些数据作为 websocket 服务器并将其作为 discord bot 发送。
这就是我尝试实现这个想法的方式:
# -*- coding: utf-8 -*-
import asyncio, websockets, discord
client = discord.Client()
channel = client.get_channel(...)
print(channel)
async def response(websocket, path):
global channel
r = await websocket.recv()
print(r)
await channel.send(str(r))
PORT = os.environ.get('PORT')
start_server = websockets.serve(response, '0.0.0.0', os.environ.get('PORT'))
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()
但我不知道如何在这样的代码中启动一个 discord 机器人,以便它与 websocket 服务器并行工作。请告诉我该怎么做。
最佳答案
我的第一个想法是使用 threading在单独的线程中运行 websockets
但它不能在线程中使用 asyncio.get_event_loop()
。
因为 websockets
使用 asyncio
就像 discord
所以我尝试在 asyncio
中使用相同的循环来启动两者。
在深入了解 discord.run()
的源代码后,我发现它使用了 asyncio.get_event_loop().run_forever()
所以我尝试启动 websockets
没有 asyncio.get_event_loop().run_forever()
并且对我有用。
# --- start ---
# - websockets -
server = websockets.serve(response, '0.0.0.0', '8000')
asyncio.get_event_loop().run_until_complete(server)
# without `run_forever()` because `client.run()` will run `run_forever()`
# - discord -
TOKEN = os.getenv('DISCORD_TOKEN')
client.run(TOKEN) # `client.run()` will run `run_forever()`
我用来测试它的最小工作代码
main.py(带有 discord 客户端
和 websockets 服务器
)
import os
import asyncio
import discord
import websockets
# --- websockets ----
async def response(websocket, path):
message = await websocket.recv()
print(f"[ws server] message < {message}")
#answer = f"[{message}]"
#await websocket.send(answer) # if client expect `response` then server has to send `response`
#print(f"[ws server] answer > {answer}")
# `get_channel()` has to be used after `client.run()`
channel = client.get_channel(MY_CHANNEL_ID) # access to channel
await channel.send(f'websockets: {message}')
# --- discord ---
MY_CHANNEL_ID = 709507681441808388 # you have to use own number
client = discord.Client()
# `get_channel()` has to be used after `client.run()`
#print(client.get_channel(MY_CHANNEL_ID)) # None
@client.event
async def on_message(message):
if message.author != client.user:
print('message.content:', message.content)
# --- start ---
# - websockets -
print('running websockets ws://0.0.0.0:8000')
server = websockets.serve(response, '0.0.0.0', '8000')
asyncio.get_event_loop().run_until_complete(server)
# without `run_forever()` because `client.run()` will run `run_forever()`
# - discord -
print('running discord')
TOKEN = os.getenv('DISCORD_TOKEN')
client.run(TOKEN)
client.py(我用来测试websockets server
的websockets client
)
import asyncio
import websockets
uri = 'ws://0.0.0.0:8000'
async def send_message():
async with websockets.connect(uri) as websocket:
message = input("msg: ")
await websocket.send(message)
print(f"[ws client] message > {message}")
#answer = await websocket.recv()
#print(f"[ws client] answer < {answer}")
asyncio.get_event_loop().run_until_complete(send_message())
顺便说一句:
你不能在 client.run()
之前使用 get_channel()
因为它给出了 None
而我在 中使用它响应()
编辑:
我使用 on_ready()
来使用 get_channel()
- 如果我有权访问 ,我还会检查
。response()
> channel
为了确保我在开始 discord
之前设置了 channel = None
。
主.py
import os
import asyncio
import discord
import websockets
# --- websockets ----
async def response(websocket, path):
global channel
message = await websocket.recv()
print(f"[ws server] message < {message}")
#answer = f"my answer: [{message}]"
#await websocket.send(answer) # if client expect `response` then server has to send `response`
#print(f"[ws server] answer > {answer}")
# `get_channel()` has to be used after `client.run()`
if not channel:
print('[ws server] getting discord channel:', MY_CHANNEL_ID)
channel = client.get_channel(MY_CHANNEL_ID) # access to channel
if not channel:
print("[ws server] can't access channel:", MY_CHANNEL_ID)
else:
print('[ws server] channel:', channel, 'message:', message)
#await channel.send(f'websockets: {message}')
await channel.send(message)
# --- discord ---
MY_CHANNEL_ID = 709507681441808388 # you have to use own number
client = discord.Client()
# `get_channel()` has to be used after `client.run()`
#print(client.get_channel(MY_CHANNEL_ID)) # None
@client.event
async def on_ready():
global channel
if not channel:
print('[on_ready] getting discord channel:', MY_CHANNEL_ID)
channel = client.get_channel(MY_CHANNEL_ID) # access to channel
if not channel:
print("[on_ready] can't access channel:", MY_CHANNEL_ID)
else:
print('[on_ready] channel:', channel)
@client.event
async def on_message(message):
if message.author != client.user:
print('[on_message] message.content:', message.content)
# --- start ---
# - websockets -
print('running websockets ws://0.0.0.0:8000')
server = websockets.serve(response, '0.0.0.0', '8000')
asyncio.get_event_loop().run_until_complete(server)
# without `run_forever()` because `client.run()` will run `run_forever()`
# - discord -
channel = None # set default value at start
print('running discord')
TOKEN = os.getenv('DISCORD_TOKEN')
client.run(TOKEN)
对于bot
main-bot.py
import os
import asyncio
import discord
from discord.ext import commands
import websockets
# --- websockets ----
async def response(websocket, path):
global channel
message = await websocket.recv()
print(f"[ws server] message < {message}")
#answer = f"my answer: [{message}]"
#await websocket.send(answer) # if client expect `response` then server has to send `response`
#print(f"[ws server] answer > {answer}")
# `get_channel()` has to be used after `client.run()`
if not channel:
print('[ws server] getting discord channel:', MY_CHANNEL_ID)
channel = bot.get_channel(MY_CHANNEL_ID) # access to channel
if not channel:
print("[ws server] can't access channel:", MY_CHANNEL_ID)
else:
print('[ws server] channel:', channel, 'message:', message)
#await channel.send(f'websockets: {message}')
await channel.send(message)
# --- discord ---
MY_CHANNEL_ID = 709507681441808388 # you have to use own number
bot = commands.Bot(command_prefix="!")
# `get_channel()` has to be used after `client.run()`
#print(client.get_channel(MY_CHANNEL_ID)) # None
@bot.event
async def on_ready():
global channel
if not channel:
print('[on_ready] getting discord channel:', MY_CHANNEL_ID)
channel = bot.get_channel(MY_CHANNEL_ID) # access to channel
if not channel:
print("[on_ready] can't access channel:", MY_CHANNEL_ID)
else:
print('[on_ready] channel:', channel)
#@bot.event
#async def on_message(message):
# if message.author != bot.user:
# print('message.content:', message.content)
@bot.command()
async def ping(ctx):
await ctx.send('pong')
# --- start ---
# - websockets -
print('running websockets ws://0.0.0.0:8000')
server = websockets.serve(response, '0.0.0.0', '8000')
asyncio.get_event_loop().run_until_complete(server)
# without `run_forever()` because `client.run()` will run `run_forever()`
# - discord -
channel = None # set default value at start
print('running discord')
TOKEN = os.getenv('DISCORD_TOKEN')
bot.run(TOKEN)
关于python - 一个应用程序中的 discord bot 和 websocket 服务器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/66221714/
因此,我想创建一个 bot/incoming webhook 来读取群组中的所有消息并将其复制到电子表格中。我在这里要问的是,机器人或传入的 webhook 可以读取整个群组消息吗?在 google
我正在使用 Microsoft Bot Framework 开发一个机器人,在该机器人中,机器人将通过向用户发送一些图像来响应。我用 slack 和 skype 配置了它。 在 slack 中图像正在
我试图让我的机器人与用户开始对话,但我不知道应该从代码中的哪个位置发送消息。启动 convo 的文档在这里,但不是很有帮助:http://docs.botframework.com/connector
我正在创建 Telegram Bot 。我需要跟踪添加用户和添加用户的时间。我如何使用 Telegram API 来做到这一点? 最佳答案 在使用 Telegram API 的群组中,您可以调用 ne
我已经创建了几个 Telegram 机器人。它们适用于我的帐户,也适用于我测试过的其他几个帐户。 但我收到一些用户的报告,称机器人从不响应。 是否有一些用户设置会阻止帐户从机器人获取消息?或者任何其他
如果在一段时间内没有用户输入,我有一个关于取消提示或对话框的问题。 我需要一种方法来以某种方式在提示中超时。 Example: Bot prompts the user: "How old are y
我有一个用例,当我的机器人需要在一天中的特定时间向用户发送消息时。假设每天早上 6 点。 我正在使用预定的 azure Webjob 发送这些消息。消息将在 Slack 和 Skype 客户端中传递。
我是 Microsoft bot 的新手。我的公司有自己的通信应用程序,我想将我的机器人与通信应用程序连接起来,我的客户可以在我公司的通信应用程序上使用我的机器人。我读到它需要使用 Direct Li
我在 sdk V4 Bot 中实现了一个中间件来拦截 bot 和用户之间的每条消息并记录该自定义 mongo Db。我正在尝试为使用 SDK v4 构建的 Bot 实现类似的概念。看起来我可以使用以下
我对编程和学习还很陌生。我认为制作一个不和谐的机器人是一种很好的学习方式,我很享受,只是有点卡住了。所以我的机器人是私有(private)的,我们的不和谐服务器中有一个正在运行的笑话,每当用户发送“k
如何让机器人假装它正在输入消息? 当机器人假装输入时,聊天中会出现以下文本: 我使用 python aiogram框架,但对 native Telegram API 的建议也会有所帮助。 最佳答案 我
我有一个像这样的 Telegram Bot : 通过 webhook 获取更新 语言:C#(我也欢迎其他语言的回答) 我们有以下用户场景: 向机器人发送/MyPhoto a_parameter命令 向
我加入了一个 Telegram Bot ,但我不知道它的所有者。是否可以找到 Telegram Bot 的所有者? 最佳答案 根据 Telegram MTProto protocol 不可能看到 Te
我已经创建了一个电报机器人并按照文档中的描述设置了一个 webhook。出于测试目的,我已经设置了它,因此一旦您向机器人发送一条消息,它就会用相同的消息回复。 现在我遇到的问题是来自电报的更新非常缓慢
是否可以将位置从 Telegram 发送到 Bot,这是在 Bot Framework 中制作的? 我将我的位置从我的 Telegram 帐户发送到我的 Bot,但服务器没有收到它们(我没有收到回复)
我在 Telegram 上创建了一个组并创建了一个机器人并添加进来。 我正在尝试向我创建的组发送消息,错误如下所示 {"ok":false,"error_code":403,"description"
使用 Microsoft Bot Framework V3 我开始使用登录卡。 我从示例代码页做了一个简单的剪切并粘贴到我的代码中,假设它有效(编译): https://docs.botframewo
当用户刚刚打开聊天时,机器人如何向用户发送消息。 例子: 用户已经添加了 Telegram bot到他的联系人列表并开始对话 稍后,用户打开与该机器人的聊天窗口 机器人“看到”该用户已打开聊天窗口,但
将 XCode 更新到版本 11.4 (11E146) 后,我不再在机器人设置中看到存储库分支。但是我在 Source Controll Navigator 中看到了这些存储库分支。有谁知道我该如何解
我想将机器人的位置发送给用户,我在谷歌上搜索了很多,但我发现只有这种情况“将用户的位置发送给机器人”我想要相反的情况,意思是:“发送机器人的位置给用户”。这是我的想法:机器人的所有者是一个司机,他想与
我是一名优秀的程序员,十分优秀!