pika模块和argparse模块

发布时间 2023-07-26 18:06:41作者: 性格如此w

工作知识

argparse

argparse是一个标准库模块,提供了一种方便灵活的方法来解析 Python 脚本那种的命令行参数。

从命令行运行 Python脚本的同时,可以将参数传递给脚本,这些参数可用于控制脚本的行为或者提供输入数据。argparse允许以结构化方式定义和处理这些命令行参数。

import argparse  # 导入

第一步是创建一个ArgumentParser对象,它将处理脚本的命令行参数:

parser = argparse.ArgumentParser(description='Description of your script')

添加参数,可以使用该方法向解析器添加各种参数add_argument()。每个参数都定义有自己的名称、类型、默认值、帮助文本和其他可选属性:

parser.add_argument('filename', type=str, help='Name of the file')
parser.add_argument('--verbose', '-v', action='store_true', help='Enable verbose output')
parser.add_argument('--count', type=int, default=1, help='Number of times to repeat')

解析参数:定义参数后,您可以argparse使用以下方法指示解析命令行参数parse_args()

args = parser.parse_args()
# 脚本运行完之后 通过这条命令 保存到args中 直接从args点就就可以取到自己想要的

访问已解析的参数:该parse_args()方法返回一个对象,该对象保存命令行参数的已解析值。您可以使用调用中定义的属性来访问这些值add_argument()

访问已解析的参数:该parse_args()方法返回一个对象,该对象保存命令行参数的已解析值。您可以使用调用中定义的属性来访问这些值add_argument():

运行脚本:当您从命令行运行脚本时,您可以传递如下参数:

python script.py file.txt --verbose --count 3

pika

pika是一个Python库,用于与RabbitMQ通信,实现消息队列和消息代理。RabbitMQ是一种流行的消息代理,它实现了AMQP(高级消息队列协议),使得应用程序能够异步地发送和接收消息,实现解耦和灵活的消息传递。

pika提供了许多功能,允许您在 Python 程序中使用 RabbitMQ 进行以下操作:

使用channel()方法创建信道的一般步骤如下:

  1. 首先,通过pika.BlockingConnectionpika.SelectConnection建立一个到 RabbitMQ 服务器的连接。
  2. 然后,使用connection.channel()方法创建一个信道。该方法将在连接上打开一个新的信道,并返回一个代表该信道的对象。
  3. 之后,你可以使用这个网关对象执行消息操作,如声明队列、发送消息、接收消息、确认消息等。
import pika
# 明文凭据
credentials = pika.PlainCredentials('账号','密码')

# 建立到 RabbitMQ 服务器的连接
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
# 创建信道
channel = connection.channel()

# 声明一个队列
channel.queue_declare(queue='queue_name')

# 发送消息到队列
channel.basic_publish(exchange='', routing_key='hello', body='Hello, RabbitMQ!')

# 关闭信道和连接
channel.close()
connection.close()