Python:通过cog和后台任务向不一致的特定频道发送消息
Python是一种高级编程语言，具有简洁、易读、易学的特点。它广泛应用于前端开发、后端开发、软件测试、数据库、服务器运维、云原生、网络通信、网络安全、音视频、多媒体处理、人工智能、物联网、移动开发、存储、区块链、元宇宙等领域。
在云计算领域中，Python被广泛使用，特别是在自动化部署、云资源管理、数据分析和机器学习等方面。Python的简洁语法和丰富的第三方库使得开发人员能够快速构建和部署云计算应用。
对于通过cog和后台任务向不一致的特定频道发送消息的需求，可以使用Python的异步编程特性和相关库来实现。以下是一个完善且全面的答案：
概念： 通过cog和后台任务向不一致的特定频道发送消息是指利用Python中的cog库和后台任务来实现向不同频道发送消息的功能。cog是一个Python库，用于构建异步、分布式、可扩展的应用程序。
分类： 这个需求可以归类为消息队列和异步任务处理。
优势：
- 异步处理：使用异步编程可以提高应用程序的性能和响应能力，同时减少资源的占用。
- 分布式架构：通过使用消息队列，可以实现分布式架构，提高系统的可靠性和可扩展性。
- 解耦合：使用消息队列可以将消息的发送者和接收者解耦，使得系统更加灵活和可维护。
应用场景：
- 实时通知：可以通过cog和后台任务向不同的频道发送实时通知，例如向移动设备推送通知。
- 日志处理：可以将日志消息发送到不同的频道，方便日志的集中管理和分析。
- 任务调度：可以将任务消息发送到不同的频道，实现任务的异步执行和分布式处理。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq
- 腾讯云函数计算 SCF：https://cloud.tencent.com/product/scf
以上是关于通过cog和后台任务向不一致的特定频道发送消息的完善且全面的答案。
相关·内容
1回答
需要一些帮助，试图在不和谐的频道和电报频道之间架起一座桥梁。我收到了来自不和谐的信息，发送到电报，但我很难得到电报信息发送到不和。我正在收到电报信息，但我想不出如何把它们传递给不和谐的人。
from discord.ext import commands
import telegram.ext
from telegram.ext import MessageHandler, Filters, Updater
telegram_token = 'str'
telegram_group = 'str'
discord_channel = 'int'
浏览 11提问于2020-01-01得票数 2
我希望创建一个机器人，将发送一条消息到一个频道时，视频上传到指定的频道。我猜一定有某种api可以使用，但我不知道是哪种api以及如何使用的。如果有人能帮我，那就太好了！:)
浏览 6提问于2021-02-04得票数 0
我有一个不协调的Python机器人，我正在尝试运行一个后台任务，它将每X秒不断地向通道发送一条消息-不需要命令。目前有任意5秒用于测试目的。 这里是有问题的cog文件(为了提高效率，导入和其他东西被删除了) class TestCog(commands.Cog):
def __init__(self, bot):
self.bot = bot
self.mytask.start()
@tasks.loop(seconds=5.0)
async def mytask(self):
channel = client.get
浏览 33提问于2020-06-23得票数 0
我一直在研究discord.py机器人的审计日志。我被困在如何提到一个消息被编辑的频道。示例:用户编辑消息#general，如何使我的bot获得用户编辑的消息的通道ID。我希望嵌入引用谁编辑了消息，之前和之后，以及消息是在哪个频道编辑的。
这就是我目前的情况：
class Log(Cog):
def __init__(self, bot):
self.bot = bot
@commands.Cog.listener()
async def on_ready(self):
print("Bot is online.")
@Cog.listener()
asy
浏览 4提问于2021-01-14得票数 1
回答已采纳
有时我需要发送消息到一个频道，我不在乎频道是否有任何成员，消息是否丢失。
是否有可能在不加入的情况下向频道发送消息？
浏览 2提问于2017-02-15得票数 0
回答已采纳
我在存储PushNotificationChannel方面有一个很大的问题。不能将itselt类型存储在LocalSettings中。
我需要它在得到新频道后关闭频道。每次启动应用程序(如文档所述)时，我都会请求新的频道(如文档所述)，有时我会获得新的频道(与以前的不同)，而前一个仍然有效(导致重复的推送通知)。所以当我得到新频道时，我想在关闭旧频道之前。
我还尝试使用以下方法将其序列化为流：
var serializer = new DataContractSerializer(typeof(PushNotificationChannel));
MemoryStream ms = new M
浏览 4提问于2016-05-05得票数 0
回答已采纳
我有一个后台任务，它在通道中发送一条消息，告知通道ID存储在JSON中。即使频道被删除，新的频道ID也会替换JSON文件中的旧频道ID。当后台任务再次发送时，我将获取discord.errors.NotFound: 404 Not Found (error code: 10003): Unknown Channel。我试图将这段代码chanid = get_general()放在后台任务代码之外，希望它能在循环中引入新的通道ID，但我觉得这里缺少一些东西。
try:
with open("channels.json", 'r') as fp:
浏览 0提问于2021-11-12得票数 0
1回答
我正在设计一个使用PubNub实现实时消息的应用程序。我面临一个关于1比1聊天的问题。这是我的场景：
我有一个用户A，所以如果A想接收来自另一个用户的所有消息，A必须订阅一个公共频道，称为PUB频道。
用户B知道A的公共信道，所以B或其他人可以向该信道发送消息。现在就这么好。
但是当我打开这个应用程序时，我想显示一个新的人发送给我的用户列表，或者是离线消息。
我可以从我的公共频道收到所有信息。但是如何对用户进行过滤呢？如果有很多信息，这太难了。
对于所有这些信息，我只想得到关于我和C的消息，或者我和B...etc，有人对此有什么想法吗？谢谢,
浏览 4提问于2014-04-13得票数 2
我正在经营一项关于在线销售/购买的业务，我主要使用Discord来联系我的供应商/客户。手动向我的每个供应商发送私人消息，并组织与当前不一致界面的联系(在特定服务器之外)，这变得非常令人厌烦 我感兴趣的是:我是否可以创建一个脚本，当我运行它时，可以向我的朋友列表中的多个人发送一条私人消息(给出一个不一致的名字列表)，而不使用不一致的服务器？服务器/频道选项对我来说不可行，使用其他应用程序也不可行。我会开始在任何编程语言中构建它，我只是对它是否可能感兴趣，因为我还没有找到任何关于它的信息。
浏览 15提问于2020-01-11得票数 0
我试图进行一次民意调查，但我看到的所有这些都有用异步创建的时间限制，但我想要做的是，当投票达到表情符号✅的5个反应时，而不是有一个时间限制，将消息发送到另一个频道，我已经完成了投票本身。
@cog_ext.cog_slash(name='poll', description='Create a poll')
@commands.has_role(Staff_role)
async def poll(self, ctx, message):
embed=discord.Embed(title=f'Poll por {ctx.author}'
浏览 2提问于2022-06-29得票数 1
回答已采纳
在试图向特定的电报频道发送消息时，我遇到了以下错误：
TimedOut: Timed out
The read operation timed out
我从python电报到bot使用的方法是send_message。
虽然我的bot收到了这个错误，但它仍然将消息发送到通道，而且由于我没有捕获该异常，消息中的所有数据都丢失了，但是在特定的一段时间之后，我确实需要从该通道删除消息。
这是可以的，即使机器人发送消息，即使它被超时？如何防止再次发生这种情况，或在发送后从通道中删除此类消息？
浏览 2提问于2021-07-15得票数 1
回答已采纳
1回答
我用Python编写了一个slash，它的工作原理与我在聊天通道中使用斜杠命令时设计的一样，但是当我试图在与另一个用户的直接消息中与Bot交互时，就不会显示响应。然而，当我查看应用程序日志时，我仍然会收到来自Slack的帖子，所以我的应用程序正在接收响应并发送回复。
我启用了以下权限：
以MyBotName形式发送消息
以用户身份发送消息
将文章发送到Slack的特定频道
添加带有用户名@mybotname的bot用户
向消息中添加斜杠命令和添加操作(并查看相关内容)
查看消息中的一些URL
向消息中添加链接预览
在我的代码中，我创建了以下api_call：
浏览 5提问于2019-01-28得票数 2
我试图使我的不和谐的机器人踢一个成员，并发送“用户禁用，因为原因”到一个特定的渠道，而不是使用命令的渠道。我使用的代码：
@bot.slash_command(description = "Kick someone", guild_ids=[1041057700823449682])
@commands.has_permissions(kick_members=True)
@option("member",description = "Select member")
@option("reason",description = &
浏览 23提问于2022-11-15得票数 2
回答已采纳
我正在研究一个伐木机器人。为了做到这一点，我使用了带有jump_url的on_message来检测链接，但是机器人只是发送垃圾邮件，我猜这是因为它读取自己的消息。
我试图通过检查消息作者是否是用户来阻止它，但这并没有解决它。每当我输入任何东西时，它都会记录下来，并有链接，即使我没有放入任何链接。
这是在齿轮上。
@commands.Cog.listener()
async def on_message(self, message):
embed=discord.Embed(title="Message from {} contains a link ".fo
浏览 0提问于2021-11-15得票数 0
编辑:我终于让代码工作了，但只有一个频道。有没有办法让它变成两个频道？我试过做'or‘，但不起作用。它只接受一个通道，或者有时会忽略所有通道。
例如。删除所有用户消息并进行测试，但!ask或！every in general和!test in test除外
@commands.Cog.listener()
async def on_message(self, message):
if not message.guild:
return
if not message.channel.name == 'general':
re
浏览 0提问于2020-07-16得票数 1
我试图从用户那里得到一条消息，然后将其发送到特定的文本频道。信息应嵌入其中。但是我不喜欢当您有一堆字段时，我希望discord.Embed()中的描述保存文本内容。但是它给了我一个错误TypeError: Object of type Message is not JSON serializable
这是我的密码：
class Changelog(commands.Cog):
def __init__(self, client):
self.client = client
@commands.Cog.listener()
async def on_r
浏览 3提问于2020-09-27得票数 0
回答已采纳
1回答
嗨，伙计们，我正在尝试让机器人在特定的频道上自动发送消息。我获取通道ID并将其传递到if condition (a_string.find ('data: []')! = -1)中。然而，这段代码给出了这个错误。参见OUTPU错误。 附注:我正在使用复制，实时是文件名(Live.py) from discord.ext import commands
from Naked.toolshed.shell import execute_js, muterun_js
import sys
class Live(commands.Cog):
def __init__(sel
浏览 14提问于2021-04-11得票数 0
回答已采纳
我创建了一个Slack应用程序，它向一个频道发送一系列交互式消息。在我的Slack仪表板中，我看到我可以创建和删除钩子。现在，我在代码中设置的钩子url是Slackbot通道的一个。
但问题是这样的信息只会发送给我。
我想发送Slackbot消息给爱丽丝在情况A，鲍勃在情况B不只是给我自己，谁配置了应用程序。
做这件事最好的方法是什么？
浏览 3提问于2020-04-14得票数 1
回答已采纳
如果您不是python的管理员，是否可以阅读来自某个组的不一致消息？我发现discord.py是最常用的与不和谐相关的库，但我只知道如何创建一个机器人。我只想阅读群中特定文本频道的消息。 这个是可能的吗？或者我需要使用网络刮板吗？
浏览 16提问于2020-04-20得票数 1
回答已采纳
所以我在这里做一个小项目，我很想有一个“请在这个服务器中键入一个频道的名称”的功能。
因此，机器人要求一个通道名，我输入例如"#changelog“，然后它会要求在该通道中写什么等等。所以需要获得通道id (我猜是这样)，但我不想让用户写ID，而只写#server-name。然后每当我这么做的时候，机器人就会在那个通道上写字。
这是我现在的密码！
class Changelog(commands.Cog):
def __init__(self, client):
self.client = client
@commands.Cog.listener(
浏览 5提问于2020-09-26得票数 0
回答已采纳
我需要知道如何在2个用户之间发送和订阅消息的安全方式。
例如：user1在频道上发送message1：user1-2 user2订阅频道user1-2和接收message1
如何确保user3不会截获user1和user2之间的聊天？我如何确定user3不会订阅频道user1-2
我用的是Laravel5，Node.js，Redis，Socket.io。我只想知道怎么保证安全。
浏览 3提问于2015-12-25得票数 0
我能够使用Bot向单个用户和团队的一般通道发送消息。我想知道的是，是否有可能向低于目标的观众发送信息！
特定团队的专用频道Any M365 Group和Azure AD Security GroupAny Distribution
如有可能，请提供任何链接或文件。提前谢谢。
浏览 4提问于2022-07-20得票数 0
请帮帮我，我希望我的机器人发送日志(比如“用户进入频道”“和”消息删除了“，”用户加入了服务器“”)。
@commands.Cog.listener()
async def on_message_delete(self, message):
deleted = Embed(
description=f"Message deleted in {message.channel.mention}", color=0x4040EC
).set_author(name=message.author, url=Embed.Emp
浏览 1提问于2020-11-11得票数 0
当我在twitch上开始直播时，我正在尝试让我的机器人向指定的频道发送消息。到目前为止，我一直在纠结于从我的状态中获取正确的“活动”，这代表了我正在流媒体。这就是我到目前为止得到的： class Stream(commands.Cog):
def __init__(self, bot):
self.bot = bot
@commands.Cog.listener()
async def on_ready(self):
print("Streamingstatus loaded")
浏览 19提问于2021-02-08得票数 0
回答已采纳
我只是重新阅读了Sandi在Ruby中的实用面向对象编程，特别是关于测试的章节。还有一个非常有用的演讲，我推荐Rubyist看：
她说要检验这些病例：
传入查询消息:通过断言它们返回的内容来测试它们。
传入命令消息:测试直接公共副作用(我对此有一个问题)
发送给self的查询消息:不要测试它们
发送给self的命令消息:不要测试它们
传出查询消息:不要测试它们
传出命令消息:测试它们是否被发送
对于#2，她提供了一个类似于此的示例：
#class
class Gear
attr_reader :cog
def set_cog(cog)
@cog
浏览 5提问于2014-02-18得票数 3
从Python发送消息到电报频道是非常容易的，只需创建一个Telegram bot，保存它的令牌id并将bot添加到通道中作为admin，那么Python代码是
import requests
TOKEN = "..." # bot token ID to access the HTTP API
CHANNEL_ID = "..." # for example @durov
MSG = "..."
url = "https://api.telegram.org/bot" + TOKEN + "/sendMessage?ch
浏览 3提问于2020-10-25得票数 1
回答已采纳
我找不到任何可以向MS Teams频道发送简单消息的东西，我使用的是Csharp，不需要回复消息。
浏览 122提问于2020-04-14得票数 1
回答已采纳
1回答
我刚开始与不和谐的机器人打交道，我想知道是否有人知道向特定频道发送嵌入式消息的方法。到目前为止，我发现发送命令的唯一方法是使用RespondAsync，它直接响应在同一个通道中发出命令的人。我的bot的目的是在只读通道中创建自动链接目录，命令只会刷新它们。很难找到更多的c#示例，而且我很难理解文档。任何帮助都将不胜感激。
await ctx.RespondAsync(embed);
这就是我用来发送嵌入式设备用于测试的东西，但就像我说的，我想把它发送到指定的通道。
浏览 0提问于2022-01-23得票数 0
回答已采纳
1回答
我正在尝试制作一些东西，当一个webhook被调用时，它会通过discord向我的手机发送通知。通知应该有一个文本主体，可以是类似python错误的内容，也可以只是一些简单的文本，比如"hi there“。 我构建了一个discord机器人，它使用一个被覆盖的python BaseHTTPRequestHandler，在它自己的线程中运行，它通过client.loop.create_task(self.get_channel_by_name(name).send(message))发送服务器消息。然而，它相当慢(从webhook到服务器消息需要几秒钟到半分钟，而实际上它应该几乎是瞬间
浏览 44提问于2021-08-31得票数 0
我有一个为多个客户服务的应用程序。作为我工作流程的一部分，我想使用PubNub向客户实时发送消息，为每个客户提供一个通道。我只想给我的客户一个订阅密钥，他们可以用它来收听他们特定频道上的消息。
这是Pubnub上支持的场景吗？有什么正确的方法来设置这个？我假设我将在我这边完成所有的设置，同时处理所有的账单，同时只需将我的客户的订阅密钥交给他们的频道。但现在，在我的Pubnub帐户上，我只看到一个“订阅密钥”。我希望所有的密钥和客户数据相互隔离。
浏览 3提问于2014-08-19得票数 1
回答已采纳
1回答
因此，当用户发送消息时，我希望我的机器人向该频道发送一个带有表情符号的消息 到目前为止，我已经能够将消息发送到特定的通道，但在那之后，我就不能将消息发送到任何删除了消息的通道。 也许我只是不知道这些属性。 提前感谢大家的帮助！ @bot.event
async def on_message_delete(ctx):
if ctx.author.id != 835676293625282601:
author = ctx.message.author
del_msg = await channel.send(":eyes:")
浏览 20提问于2021-04-30得票数 1
回答已采纳
1回答
我想在电报上创建一个匿名的组动态。我知道你可以使用任何用户名并在电报中匿名，但如果你在某人的联系人名单上，他们总是可以给你发短信--即使你更改了你的用户名。例如，你不能在电报组中对已经认识你的人匿名。
我想让联系人匿名。我知道今天没有办法这样做。对，是这样?
我的目标是拥有一个分配给某所学校的电报私人频道，比如Harvard.edu和任何人都可以加入，但只有那些验证了他们的电子邮件的用户才能通过向该频道发送消息参与进来。由于普通用户不能向通道发送消息，所以投递将通过机器人完成。
它是这样的：
有人试图向机器人发送新消息，
bot验证用户
机器人中继器发送到频道。
这样看起来
浏览 9提问于2019-12-03得票数 1
我想从我的闲置通道“一般”中获取消息，可能带有参数，如检索最近50条消息。 我查过了文档，有像发送消息，列出频道，离开频道，查找频道ID等所有的东西，但我没有找到任何可以帮助我使用该频道ID“一次”获得频道消息的东西。 这个函数在python-slackclient中可用吗？或任何解决方法？
浏览 105提问于2021-02-22得票数 1
回答已采纳
由于这样或那样的原因，在我的discord.py机器人上，For循环似乎不想完成。循环的重点是向大约20个用户发送相同的消息。问题是一些用户没有收到这些消息，我相当确信问题出在循环中。
for server_member in ctx.message.server.members:
await client.send_message(server_member, message)
我对for循环没有太多的经验，所以在我看来，这似乎是最有可能的问题。
这是每次尝试发送消息后留下的错误代码。
Ignoring exception in command massdm
Traceback (m
浏览 37提问于2018-06-11得票数 -2
回答已采纳
2回答
当我在不和谐中键入命令!sleeper时，然后紧接着键入!hello。机器人基本上处于暂停10秒，因为它正在处理!sleeper。在10秒之后，它发送消息I have been sleeping for 10 seconds，然后紧接着发送Hello partner!。如果有人发送!sleeper命令，我如何才能使整个机器人不被“暂停”。
现在发生了什么：
I型!sleeper
I型!hello
机器人等待9-10秒
Bot发送I have been sleeping for 10 seconds
Bot发送Hello partner!
我想要的：
I型!sle
浏览 3提问于2021-11-20得票数 0
是否可以在不属于JavaScript的服务器上侦听消息？我一直在研究discord.js，但听起来你只能在你管理的频道/服务器中创建机器人。我见过关于"self botting“是一种可以禁止的攻击的东西，但我实际上并不想向服务器发送消息(听起来他们只是不想假装成用户，所以我在想我的用例应该被允许吗？)。我只想监听消息，这样我就可以在我的机器上运行其他JS代码。
浏览 17提问于2021-04-22得票数 0
3回答
我正在尝试使测试不一致机器人的状态在每10秒两条消息之间进行更改。我需要在状态消息更改时执行脚本的其余部分，但每当我试图使其工作时，都会弹出一个错误。我的脚本中有线程，但我不完全确定如何在这种情况下使用它。
@test_bot.event
async def on_ready():
print('Logged in as')
print(test_bot.user.name)
print(test_bot.user.id)
print('------')
await change_playing()
@test_bot
浏览 0提问于2017-09-18得票数 9
回答已采纳
1回答
我正在尝试使用和JMS构建一个简单的聊天应用程序。
我已经设置了两个频道(msg和ack)。
msg发送消息，ack接收确认。
如果确认未在指定时间内收到，如何再次发送消息？
请询问是否需要更多的细节。
浏览 0提问于2013-10-07得票数 0
回答已采纳
我用python创建了一个不和谐的机器人，但是cogs不在我的bot中，请告诉我，这段代码中有错误吗？
import discord
from discord.ext import commands
import os
from help_cog import help_cog
from music_cog import music_cog
intents = discord.Intents.default()
intents.message_content = True
bot = commands.Bot(command_prefix='=', intents
浏览 18提问于2022-11-18得票数 1
我正在尝试制作一个机器人，它将检测消息何时被删除，并将消息发送到具有消息内容的同一个通道。
我希望能够做到这一点，即使消息不在机器人的cached_messages中，所以我使用on_raw_message_delete(payload)。
我的问题是，当尝试使用await channel.fetch_message(payload.message_id)从通道获取消息时，我会得到以下错误：
discord.errors.NotFound: 404 Not Found (error code: 10008): Unknown Message
我认为这是因为消息已经从频道中消失了，但我不知道如何
浏览 0提问于2020-10-06得票数 1
回答已采纳
1回答
我想要创建一个应用程序，让用户在我的网站上，以实时消息对方。频道似乎是合乎逻辑的选择，然而，我在网上找到的所有资源都是为了建立更多的聊天室。在哪里可以找到关于进行一次点对点聊天的教程或资源？
浏览 0提问于2018-07-30得票数 0
回答已采纳
4回答
我正在写一个小的消息记录程序，我希望机器人只记录来自一个特定的行会的消息，为此，我检查了message.guild.id。然而，当在DM通道中发送消息时，这会引发问题。我想让机器人完全忽略Dm通道，但我没那么幸运 代码： @commands.Cog.listener()
async def on_message(self, message):
if message.guild.id == Guild ID HERE:
print(f"{message.author} said --- {message.clean_content} --
浏览 30提问于2020-07-27得票数 5
回答已采纳
我正在设计一个应用程序，当我的python代码发生问题(例如，新用户在我的网站上注册)时，我可以发送通知到我的不和谐通道。这将是一个单向的沟通，因为只有python应用程序会发送消息到不一致的通道。 这是我尝试过的。 import os
import discord
import asyncio
TOKEN = ""
GUILD = ""
def sendMessage(message):
client = discord.Client()
@client.event
async def on_ready():
浏览 28提问于2020-07-05得票数 7
回答已采纳
我的松懈的机器人不能发送消息到一个空间或类似的“频道名称”的频道，但是对于一个单词的频道来说效果很好。
$curl = curl_init();
curl_setopt_array($curl, array(
CURLOPT_URL => "https://slack.com/api/chat.postMessage",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURL
浏览 17提问于2022-05-06得票数 1
回答已采纳
我订阅“我的频道”，并绑定到客户端的“我的事件”。
pusher.html
<!DOCTYPE html>
<head>
<title>Pusher Test</title>
<script src="https://js.pusher.com/5.0/pusher.min.js"></script>
<script>
// Enable pusher logging - don't include this in production
Pusher.log
浏览 2提问于2020-01-21得票数 2
回答已采纳
我有一个电报机器人，我有一个私人频道。我将我的机器人作为管理员添加到此通道，以便它可以使用API在此通道上发送消息。好了，一切都很好。 但是现在，我不小心把这个频道从我的聊天列表中删除了。我的机器人仍然是管理员，并且在将消息发送到通道时不会失败。 我猜这个频道仍然存在，机器人是唯一的管理员。 我想知道如何让我的机器人将我添加回频道，因为我不能自己做，因为频道是私有的。我做了机器人后端使用C#，我有ChatID和机器人令牌。 谢谢!
浏览 44提问于2020-04-20得票数 0
所以我做了一个简单的消息嵌入，它工作，这是我的代码：
client.on('message', async message => {
if (message.content === 'hi!') {
const embed = new Discord.MessageEmbed()
.setColor("RANDOM")
.setDescription('hello there!')
.setTimestamp()
message.channel.sen
浏览 3提问于2022-01-16得票数 -1
我有一个源，它通过默认的output通道向流中的处理器发送消息。现在，我还想通过不同的频道发送失败消息。
我想我应该创建一个从Source扩展而来的可绑定接口，并使用@Output添加额外的通道。我如何确保SCDF实际上为这个频道创建一个Kafka主题？溪流的定义是什么样子的？
类似于……的东西
source | processor | sink source > error-sink
source | processor使用常规的output通道/Kafka主题，source > error-sink使用不同的通道/主题。
浏览 2提问于2017-03-07得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
