#python #pika
#python #pika
Вопрос:
Я новичок в использовании rabbitmq. Я делаю poc, сначала я пишу в очереди rabbi_mq, затем я хочу писать строку за строкой в таблице с именем product в моей базе данных. Таблица содержит 3 столбца (id, product_name, price)
Как я могу это сделать, пожалуйста?
Ниже мой код
Sender.py
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='', routing_key='hello', body= 'x12, table, 30
reciever.py
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
Комментарии:
1. Какие проблемы у вас возникают при чтении с канала?
2. @OneCricketeer проблем нет. Я просто спрашиваю, как писать в таблицах в receiver.py .
3. Что ж, сначала вам нужно использовать канал, затем открыть соединение с базой данных, проанализировать данные, а затем записать значения, как и с любой другой переменной. Здесь нет ничего специфичного для библиотеки Pika, что изменило бы способ записи в базу данных
4. Вот документация для библиотеки Postgres, если ваша проблема заключается просто в том, как взаимодействовать с базой данных psycopg.org/docs/usage.html
)
channel.basic_publish(exchange='', routing_key='hello', body= 'x13, tv, 200reciever.py
Комментарии:
1. Какие проблемы у вас возникают при чтении с канала?
2. @OneCricketeer проблем нет. Я просто спрашиваю, как писать в таблицах в receiver.py .
3. Что ж, сначала вам нужно использовать канал, затем открыть соединение с базой данных, проанализировать данные, а затем записать значения, как и с любой другой переменной. Здесь нет ничего специфичного для библиотеки Pika, что изменило бы способ записи в базу данных
4. Вот документация для библиотеки Postgres, если ваша проблема заключается просто в том, как взаимодействовать с базой данных psycopg.org/docs/usage.html
)
channel.basic_publish(exchange='', routing_key='hello', body= 'x14, desk, 100
reciever.py
Комментарии:
1. Какие проблемы у вас возникают при чтении с канала?
2. @OneCricketeer проблем нет. Я просто спрашиваю, как писать в таблицах в receiver.py .
3. Что ж, сначала вам нужно использовать канал, затем открыть соединение с базой данных, проанализировать данные, а затем записать значения, как и с любой другой переменной. Здесь нет ничего специфичного для библиотеки Pika, что изменило бы способ записи в базу данных
4. Вот документация для библиотеки Postgres, если ваша проблема заключается просто в том, как взаимодействовать с базой данных psycopg.org/docs/usage.html
)
print('published message')
connection.close()
reciever.py
Комментарии:
1. Какие проблемы у вас возникают при чтении с канала?
2. @OneCricketeer проблем нет. Я просто спрашиваю, как писать в таблицах в receiver.py .
3. Что ж, сначала вам нужно использовать канал, затем открыть соединение с базой данных, проанализировать данные, а затем записать значения, как и с любой другой переменной. Здесь нет ничего специфичного для библиотеки Pika, что изменило бы способ записи в базу данных
4. Вот документация для библиотеки Postgres, если ваша проблема заключается просто в том, как взаимодействовать с базой данных psycopg.org/docs/usage.html