|
@@ -47,7 +47,7 @@ async def run(task_id, mode, platform,trace_id):
|
|
|
def generate_trace_id():
|
|
def generate_trace_id():
|
|
|
timestamp = str(int(time.time() * 1000))
|
|
timestamp = str(int(time.time() * 1000))
|
|
|
unique_id = str(uuid.uuid4())
|
|
unique_id = str(uuid.uuid4())
|
|
|
- return f"{timestamp}-{unique_id}"
|
|
|
|
|
|
|
+ return f"{unique_id}{timestamp}"
|
|
|
|
|
|
|
|
|
|
|
|
|
async def consume_single_message(spider):
|
|
async def consume_single_message(spider):
|
