fix:修改了无法正常启动多线程的问题

This commit is contained in:
Kakune55 2024-12-26 11:14:02 +08:00
parent f219e3306f
commit 0a6a51737c
3 changed files with 16 additions and 14 deletions

10
main.py
View File

@ -2,8 +2,8 @@ from flask import *
import threading
import service.manager as manager
from init import init_all
from service.producer import run_kafka_producer
from conf.util import *
# from web import app
@ -25,15 +25,11 @@ if __name__ == '__main__':
init_all()
# 运行Kafka与Spark相关
kafka_producer_t = threading.Thread(target=run_kafka_producer())
web_t = threading.Thread(target=app.run(host=conf.get('server', 'listen'), port=conf.get('server', 'port'), debug=conf.get('server', 'debug')))
kafka_producer_t.start()
web_t.start()
manager.start()
# 运行Web服务
app.run(host=conf.get('server', 'listen'), port=conf.get('server', 'port'), debug=conf.get('server', 'debug'))

9
service/manager.py Normal file
View File

@ -0,0 +1,9 @@
import threading
from service.producer import run_kafka_producer
def start():
kafka_producer_thread = threading.Thread(target=run_kafka_producer)
kafka_producer_thread.start()

View File

@ -49,11 +49,8 @@ def delivery_report(err, msg):
pass
def run_kafka_producer():
# while True:
# order_data = generate_order_data() # 生成数据
# producer.produce('orders', order_data, callback=delivery_report) # 发送到 Kafka 的 orders 主题
# producer.poll(0) # 处理任何待处理的事件(如回调)
# time.sleep(5) # 每隔 5 秒发送一次
while True:
print("123")
time.sleep(1)
order_data = generate_order_data() # 生成数据
producer.produce('orders', order_data, callback=delivery_report) # 发送到 Kafka 的 orders 主题
producer.poll(0) # 处理任何待处理的事件(如回调)
time.sleep(5) # 每隔 5 秒发送一次