VKRB/local_quantum_simulator
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

added rabbitmq

Browse Source
This commit is contained in:
DeOwl
2025-10-25 20:24:06 +03:00
parent d900b0e23f
commit 1d0ee54b1f
4 changed files with 40 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
dockerfile
View File

@@ -1,5 +1,7 @@
FROM pennylaneai/pennylane:latest-lightning-qubit FROM pennylaneai/pennylane:latest-lightning-qubit
WORKDIR /app WORKDIR /app
COPY . . COPY ./source ./source
COPY ./main.py ./
COPY ./requirements.txt ./
RUN pip install --no-cache-dir -r requirements.txt RUN pip install --no-cache-dir -r requirements.txt
CMD ["python", "app.py"] CMD ["python", "main.py"]

20
main.py
View File

@@ -3,24 +3,24 @@ from time import sleep, time
from multiprocessing import Process, Queue from multiprocessing import Process, Queue
import source.vqe as vqe import source.vqe as vqe
import project.source.archive.mqtt as mqtt #import project.source.archive.mqtt as mqtt
if __name__ == "__main__": if __name__ == "__main__":
broker_address = "mqtt.deowl.ru" # Example public broker broker_address = "mqtt.deowl.ru" # Example public broker
broker_port = 1883 broker_port = 1883
mqttBroker = mqtt.vqeMqttBroker(broker_address, broker_port, max_connection_attempts=5) #mqttBroker = mqtt.vqeMqttBroker(broker_address, broker_port, max_connection_attempts=5)
print(mqttBroker.get_status()) #print(mqttBroker.get_status())
mqttBroker.connect_to_server() #mqttBroker.connect_to_server()
while True: #while True:
print(mqttBroker.get_status()) # print(mqttBroker.get_status())
sleep(1) # sleep(1)
# GLOBAL SYSTEM PARAMETERS # GLOBAL SYSTEM PARAMETERS
active_electrons=2 #active_electrons=2
active_orbitals=2 '''active_orbitals=2
max_iterations = 500 max_iterations = 500
conv_tol = 1e-04 conv_tol = 1e-04
step_size = 0.05 step_size = 0.05
@@ -36,4 +36,4 @@ if __name__ == "__main__":
sleep(0.1) sleep(0.1)
client.loop_stop() # Stop the background loop thread if used client.loop_stop() # Stop the background loop thread if used
client.disconnect() client.disconnect()'''

2
requirements.txt
View File

@@ -1,2 +1,2 @@
basis-set-exchange==0.11 basis-set-exchange==0.11
paho-mqtt==2.1.0 pika==1.3.2

34
source/rabbitmq_test.py
View File

@@ -1,20 +1,36 @@
import os
import sys
import pika import pika
import ssl import ssl
print
context = ssl.create_default_context() context = ssl.create_default_context()
context.verify_mode = ssl.CERT_REQUIRED context.verify_mode = ssl.CERT_REQUIRED
ssl_options= pika.SSLOptions(context=context, server_hostname="rabbitmq.deowl.ru") ssl_options= pika.SSLOptions(context=context, server_hostname="rabbitmq.deowl.ru")
credential = pika.PlainCredentials("admin", "admin") credential = pika.PlainCredentials("test", "test")
try:
def main():
connection = pika.BlockingConnection(pika.ConnectionParameters('rabbitmq.deowl.ru', virtual_host='/', port=5671, ssl_options=ssl_options, credentials=credential)) connection = pika.BlockingConnection(pika.ConnectionParameters('rabbitmq.deowl.ru', virtual_host='/', port=5671, ssl_options=ssl_options, credentials=credential))
channel = connection.channel() channel = connection.channel()
print("good")
except pika.exceptions.AMQPConnectionError as e: channel.queue_declare(queue='hello')
print(f"Connection error: {e}")
except Exception as e: def callback(ch, method, properties, body):
print(f"An unexpected error occurred: {e}") print(f" [x] Received {body}")
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()
if __name__ == '__main__':
try:
main()
except KeyboardInterrupt:
print('Interrupted')
try:
sys.exit(0)
except SystemExit:
os._exit(0)