腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
有没有办法实现卡夫卡
生产者
而不从confluent_kafka进口
生产者
?
、
、
我需要用
Python
实现卡夫卡
生产者
,但我想避免未来可能出现的新卡夫卡版本的问题,所以我想知道是否有可能在不从confluent_kafka导入
生产者
模块的情况下实现卡夫卡
生产者
?
浏览 6
提问于2021-10-08
得票数 0
回答已采纳
1
回答
生产者
/消费者的不同语言
、
我想知道是否有可能通过AMQP和RabbitMQ为
生产者
和消费者使用不同的语言? 例如:
生产者
使用Java,消费者使用
python
/php,反之亦然?
浏览 0
提问于2012-08-12
得票数 3
回答已采纳
1
回答
用于kafka
生产者
python
api部署的Azure应用程序服务
、
、
场景:我想通过管道在Azure上部署一个kafka
python
生产者
api。我有一个工件,这是一个
生产者
python
代码,需要部署在azure应用程序服务上。什么服务可以用来在azure上运行这样的
python
代码?
浏览 15
提问于2020-06-16
得票数 0
回答已采纳
3
回答
kafka认证和授权
、
我可以为
Python
生产者
使用用户名和密码吗? 可以指定任何
生产者
只能产生一个主题,比如MySQL。
浏览 1
提问于2018-06-01
得票数 2
1
回答
扭曲,ProcessProtocol如何接收标准输出w/o缓冲?
、
、
、
我使用的是外部进程,它为处理的每个数据块写短的输出行。我想在每一条线路之后作出反应,不要再拖延了。然而,似乎.outReceived() of ProcessProtocol是缓冲的。Docs声明: 其结果是,在完
浏览 5
提问于2012-03-29
得票数 3
回答已采纳
1
回答
在spring boot RabbitMQ中,发送方和接收方的最低配置要求是什么?
、
、
、
我想知道在spring boot rabbitmq (注解配置)的情况下,我们如何分别配置
生产者
代码和消费者代码。我的意思是,如果我想在spring boot中编写rabbitmq
生产者
代码,用
python
编写消费者代码,或者反之亦然-在spring boot中编写消费者代码,在
python
中编写
生产者
代码……我在spring boot中找不到单独的
生产者
和消费者配置。
生产者
端没有关于队列名称或交换类型的信息。但与此形成对比的是,在Spring启动的情况下,队列仅在发送
浏览 2
提问于2018-03-25
得票数 0
1
回答
从多线程
python
中的列表中选择项
、
我是
python
的初学者,不知道如何做到这一点:我正在运行一个
python
脚本,它每5-10秒将一个新值放入列表中。我想从另一个多线程
python
脚本中的列表中选择这些元素,但是每个线程都有一个值,所以不应该重用一个值,如果没有下一个值,那么等待下一个值出现。
浏览 1
提问于2018-07-02
得票数 0
回答已采纳
1
回答
在用
python
编写的linux守护进程中进行多处理
、
、
、
我有一个linux守护进程(基于
python
模块
python
),它需要生成多处理模块的两个进程(考虑
生产者
和使用者)来处理一些并发的I/O (
生产者
从输入流中读取,使用者使用
python
请求上传数据)根据
python
(),守护进程不允许启动子进程。我该怎么处理呢?是否有这种方法的任何文件或例子?请给我。建议。 上下文:我尝试过使用线程模块。但是,由于GIL问题,消费者很少有机会执行。
浏览 1
提问于2016-05-11
得票数 1
回答已采纳
1
回答
同时启动进程
python
3
、
、
、
我试图模拟
Python
3多处理中的
生产者
-消费者设计。主要问题是
生产者
启动,但消费者直到
生产者
完成(在这种情况下,消费者没有启动,因为
生产者
永远不会结束)。#!/usr/bin/
python
3 from queue import Queue from multiprocessing import Process
浏览 6
提问于2017-10-20
得票数 1
回答已采纳
2
回答
如何使用
python
信号在独立进程之间发送消息?
、
我有两种类型的进程。此外,我还将拥有process A和process B的多个实例。因此,所有B进程都应该向所有A进程发送消息。做这件事最好的方法是什么?注意:这些进程都不是彼此的子进程。
浏览 2
提问于2013-01-17
得票数 2
回答已采纳
4
回答
queue.Queue上的多路复用?
、
、
、
、
我如何在
Python
中实现这一点?Update0 此外,通道可能阻塞,
生产者
将阻塞,直到消费者检索该项目。我不确定
Python
的队列是否能做到这一点。
浏览 5
提问于2011-12-10
得票数 12
回答已采纳
2
回答
没有收到信息与融合卡夫卡简单的
生产者
/消费者的例子?
、
、
、
我使用使用kafka_2.11-0.10.1.1的confluent-kafka-0.9.2 (主分支)
python
绑定来运行librdkafka-0.9.2。我运行confluent producer示例如下:$
python
producer.py localhost:9095 confluent代理成功地接收到
生产者
消息: 使用者按照conf {'bootstrap.servers': broker,
浏览 3
提问于2017-01-27
得票数 0
回答已采纳
2
回答
Python
-简单地读取管道中的行
、
、
生产者
将无限期地继续生产生产线,如下所示:import time print 'Data'消费者只需要定期检查线路sys.stdin.readline() print 'Got data:', line time.sleep(1) 当我在Windows shell中以
python
producer.py |
python
cons
浏览 1
提问于2009-06-08
得票数 15
回答已采纳
3
回答
如何访问不同访问者之间共享的文件?
、
、
我有写在Java上的代码,它将所有数据写入文件,然后我有
python
脚本来处理这些数据。 它们完全分开运行,
python
脚本可以按计划运行,但它也从文件中删除了处理过的记录。问题是,在实现对文件的访问时,第一个进程中的java代码将尝试编写内容,而第二个进程中的
python
代码将尝试删除已处理的记录?
浏览 3
提问于2013-03-27
得票数 1
2
回答
将kafka消息保留在缓冲区中
、
我希望写一个
生产者
,可以保留消息在卡夫卡每16秒,并在刷新所有的消息到主题。有可能做到吗?我使用的是Kafka
python
。这个想法是:我有100条消息,在正常行为下,
生产者
会这样做:
生产者
:消息1消息2消息3...消息100 消费者:消息1消息2消息3...消息100 我想这样做:
生产者
:消息1消息2消息3 ...消息100
浏览 12
提问于2020-10-22
得票数 2
1
回答
从Kubernetes集群访问外部中央kafka消息代理
、
、
我的要求可能听起来很愚蠢,但它有点像这样: Kafka
生产者
和kafka消费者仅部署在本地Minikube集群中。Kafka代理是一个中央代理,不存在于minikube集群中。但是我不知道如何从
生产者
(部署在kubernetes中)发送消息到这个外部Kafka集群,以及如何消费它,因为消费者也在Minikube中。有人能在这方面帮我一下吗?
浏览 28
提问于2021-09-10
得票数 0
1
回答
与主进程分离的进程共享队列(
生产者
/使用者)
、
、
、
我对
Python
中的多处理非常陌生,我已经做了大量的研究,但似乎找不到我想要的东西。我遇到了一个消费者/
生产者
问题,我有一个简单的服务器,它的端点从队列中消耗,一个函数生成到队列上。队列可以是满的,所以
生产者
并不总是需要运行。 当队列没有满时,我希望
生产者
任务运行,但我不希望它阻止服务器接收或服务请求。我试过使用多线程,但是这个生产过程非常慢,而且GIL太慢了。我希望服务器一直在运行,每当队列不再满时(某些内容已被消耗),我希望启动这个
生产者
任务,作为一个单独的进程,并希望它运行,直到队列再次满
浏览 2
提问于2018-09-18
得票数 0
回答已采纳
1
回答
如何将程序的一部分作为服务一次又一次地运行?
、
、
、
以下是我的代码结构:var result = <-- a very resource heavy calculation-->;var a = result.x;print b;
浏览 1
提问于2015-11-03
得票数 0
回答已采纳
1
回答
等待信号开始从
python
中的另一个进程生成数据
、
、
我在
python
中有两个独立的过程:producer和consumer。
生产者
生成文件,消费者对文件进行一些处理。为了测试这两个应用程序,我发现自己不断地启动两个程序,而
生产者
有一个延迟功能等等,这是一个痛苦。 在
python
中实现某种信令机制的最快方法是什么,以便consumer说"GO!
浏览 2
提问于2015-06-11
得票数 0
回答已采纳
1
回答
有条件重命名Jackson JSON输出
、
假设有一个类包含一个变量:public class Student {} @JsonProperty("all_grades")} 现在,我们正在构建一个可以在
生产者
之间动态切换的应用程序,因此有些可以用Java编写,有些可以用
Python
编写
浏览 1
提问于2020-06-05
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Python的Socket知识7:队列、生产者消费者模型
Python使用两个Event对象同步生产者消费者问题
Day 063 生产者
内容生产者的半衰期赛道
华云数字如何助力生产者
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
云直播
活动推荐
运营活动
广告
关闭
领券