如何从目录循环记录并传递到 python 中的 MQ 函数？

Question

我在目录 XML.

中设置了 xmls

123.xml
234.xml
567.xml

我希望我的代码循环进入目录和每个 xml 并传递到 MQ。

目前我可以使用当前代码成功发送 1 XML。

我不确定如何为文件夹中的每个 XML 自动创建 incremanetal UUID 以及如何在下面的代码中循环。

harcorded XML 值的当前工作代码

import ssl
!pip install pika
import pika
import uuid


def send(message):

    uui = uuid.uuid4()
    mydoc = open('123.xml')
    xml = mydoc.read()    


    ssl_options = pika.SSLOptions(ssl._create_unverified_context())
    credentials = pika.PlainCredentials(username='xxxxx', password='xxxx')
    connection = pika.BlockingConnection(pika.ConnectionParameters(host='xxxx', port=5671, virtual_host ='abcd' , 
                                        credentials=credentials, ssl_options=ssl_options))

    channel = connection.channel()
    channel.basic_publish(exchange='xxxxxx', routing_key='',properties=pika.BasicProperties(
                          headers={'uuid': str(uui)}), body=xml)
    connection.close()

    print(message + ' ' + str(uui))

    return message

如何在 python 中做到这一点？

Answer 1

您想要目录中的 XML 列表吗？

只需读取目录并获取目录中的文件，然后循环执行您的操作。

import ssl
!pip install pika
import pika
import uuid
import os


def send(message):

    xml_files = [file for file in os.listdir(path_to_your_directory) if os.path.isfile(os.path.join(path_to_your_directory, file)) and file.split('.')[-1] == 'xml']
    uui = uui = uuid.uuid4()

    for file in xml_file:
        mydoc = open(file)
        xml = mydoc.read()    


        ssl_options = pika.SSLOptions(ssl._create_unverified_context())
        credentials = pika.PlainCredentials(username='xxxxx', password='xxxx')
        connection = pika.BlockingConnection(pika.ConnectionParameters(host='xxxx', port=5671, virtual_host ='abcd' , 
                                        credentials=credentials, ssl_options=ssl_options))

        channel = connection.channel()
        channel.basic_publish(exchange='xxxxxx', routing_key='',properties=pika.BasicProperties(
                          headers={'uuid': str(uui)}), body=xml)
        connection.close()
        next_uui_hex = hex(int(str(uui).replace('-','').upper(),16) + 1)
        uui = uuid.UUID(next_uui_hex[2:11] + '-' + next_uui_hex[11:15] + '-' + next_uui_hex[15:19] + '-' + next_uui_hex[19:23] + '-' + next_uui_hex[23:])

        print(message + ' ' + str(uui))

    return message

如何从目录循环记录并传递到 python 中的 MQ 函数？

How to loop records from a directory and pass into a MQ function in python?

loops

itertools

python-3.x

pandas

pika