From 7677852f2ef30b8f84c19e3d68c7ca7e2905bbf5 Mon Sep 17 00:00:00 2001 From: Kakune55 Date: Mon, 30 Dec 2024 09:04:32 +0800 Subject: [PATCH] =?UTF-8?q?update:=E4=B8=BA=E7=94=9F=E4=BA=A7=E8=80=85?= =?UTF-8?q?=E6=B7=BB=E5=8A=A0UUID=E5=AD=97=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- service/producer.py | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/service/producer.py b/service/producer.py index 271f079..d56f8e3 100644 --- a/service/producer.py +++ b/service/producer.py @@ -1,7 +1,7 @@ import random import time import json -import threading +import uuid from datetime import datetime from confluent_kafka import Producer @@ -35,8 +35,16 @@ def generate_order_data(): date = datetime.now().strftime('%Y-%m-%d %H:%M:%S') # 随机选择是否有效 is_valid = random.choice(['Y', 'N']) - # 数据格式: 订单类别\t订单名字\t订单数量\t日期\t是否有效 - data_str = f"{order_category}\t{order_name}\t{order_quantity}\t{date}\t{is_valid}" + # 数据格式: UUID\t订单类别\t订单名字\t订单数量\t日期\t是否有效 + data_str = f"{uuid.uuid1()}\t{order_category}\t{order_name}\t{order_quantity}\t{date}\t{is_valid}" + # data_str = json.dumps({ + # "order_id": str(uuid.uuid1()), + # "order_category": order_category, + # "order_name": order_name, + # "order_quantity": order_quantity, + # "date": date, + # "is_valid": is_valid + # }) return data_str