aidlab/AiDA_Python
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

测试RABBITMQ 配置

Browse Source
This commit is contained in:
zchen
2024-03-26 14:53:58 +08:00
parent 8ae9029d7c
commit 6e70d1f111
2 changed files with 365 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/api/api_test.py
View File

@@ -12,4 +12,4 @@ router = APIRouter()
def test():
logger.info(RABBITMQ_QUEUES)
logger.info("test")
return {"message": "ok"}
return {"message": RABBITMQ_QUEUES}

364
app/logs/errors.log
View File

@@ -2580,3 +2580,367 @@
2024-03-21 11:02:07,775 service.py [line:57] INFO 123123123 ===> {'tasks_id': '123123123', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/66ab3a9c-e72f-11ee-83cb-b0dcefbff887.jpg'}
2024-03-21 11:02:07,777 decorator.py [line:11] INFO function：【sr_result】,runtime：【14.399266004562378】s
2024-03-21 11:02:07,777 decorator.py [line:11] INFO function：【sr_result】,runtime：【14.399266004562378】s
2024-03-26 11:53:20,289 api_test.py [line:13] INFO SuperResolution-local
2024-03-26 11:53:20,289 api_test.py [line:13] INFO SuperResolution-local
2024-03-26 11:53:20,290 api_test.py [line:14] INFO test
2024-03-26 11:53:20,290 api_test.py [line:14] INFO test
2024-03-26 11:54:12,641 decorator.py [line:11] INFO function：【read_image】,runtime：【0.828620195388794】s
2024-03-26 11:54:12,641 decorator.py [line:11] INFO function：【read_image】,runtime：【0.828620195388794】s
2024-03-26 11:54:12,759 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:12,759 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:12,869 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:12,869 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:13,982 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:13,982 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:14,091 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:14,091 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:15,203 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:15,203 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:15,316 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:15,316 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:16,434 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:16,434 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:16,543 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:16,543 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:18,897 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:18,897 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:19,006 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:19,006 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:20,129 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:20,129 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:20,240 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:20,240 service.py [line:57] INFO 123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:54:20,399 connection_workflow.py [line:179] INFO Pika version 1.3.2 connecting to ('18.167.251.121', 5672)
2024-03-26 11:54:20,399 connection_workflow.py [line:179] INFO Pika version 1.3.2 connecting to ('18.167.251.121', 5672)
2024-03-26 11:54:20,517 io_services_utils.py [line:345] INFO Socket connected: <socket.socket fd=1600, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9103), raddr=('18.167.251.121', 5672)>
2024-03-26 11:54:20,517 io_services_utils.py [line:345] INFO Socket connected: <socket.socket fd=1600, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9103), raddr=('18.167.251.121', 5672)>
2024-03-26 11:54:20,519 connection_workflow.py [line:428] INFO Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>).
2024-03-26 11:54:20,519 connection_workflow.py [line:428] INFO Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>).
2024-03-26 11:54:20,871 connection_workflow.py [line:293] INFO AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:54:20,871 connection_workflow.py [line:293] INFO AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:54:20,872 connection_workflow.py [line:725] INFO AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:54:20,872 connection_workflow.py [line:725] INFO AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:54:20,874 blocking_connection.py [line:453] INFO Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:54:20,874 blocking_connection.py [line:453] INFO Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:54:20,875 blocking_connection.py [line:1264] INFO Created channel=1
2024-03-26 11:54:20,875 blocking_connection.py [line:1264] INFO Created channel=1
2024-03-26 11:54:20,992 service.py [line:140] INFO [x] Sent {"tasks_id": "123456-86", "status": "SUCCESS", "message": "success", "data": "test/86316e41-eb24-11ee-89e0-505a65503f86.jpg"}
2024-03-26 11:54:20,992 service.py [line:140] INFO [x] Sent {"tasks_id": "123456-86", "status": "SUCCESS", "message": "success", "data": "test/86316e41-eb24-11ee-89e0-505a65503f86.jpg"}
2024-03-26 11:54:20,994 blocking_connection.py [line:802] INFO Closing connection (200): Normal shutdown
2024-03-26 11:54:20,994 blocking_connection.py [line:802] INFO Closing connection (200): Normal shutdown
2024-03-26 11:54:20,995 channel.py [line:536] INFO Closing channel (200): 'Normal shutdown' on <Channel number=1 OPEN conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 11:54:20,995 channel.py [line:536] INFO Closing channel (200): 'Normal shutdown' on <Channel number=1 OPEN conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 11:54:21,112 channel.py [line:1133] INFO Received <Channel.CloseOk> on <Channel number=1 CLOSING conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 11:54:21,112 channel.py [line:1133] INFO Received <Channel.CloseOk> on <Channel number=1 CLOSING conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E21F1250> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 11:54:21,113 connection.py [line:1316] INFO Closing connection (200): 'Normal shutdown'
2024-03-26 11:54:21,113 connection.py [line:1316] INFO Closing connection (200): 'Normal shutdown'
2024-03-26 11:54:21,230 io_services_utils.py [line:731] INFO Aborting transport connection: state=1; <socket.socket fd=1600, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9103), raddr=('18.167.251.121', 5672)>
2024-03-26 11:54:21,230 io_services_utils.py [line:731] INFO Aborting transport connection: state=1; <socket.socket fd=1600, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9103), raddr=('18.167.251.121', 5672)>
2024-03-26 11:54:21,231 io_services_utils.py [line:904] INFO _AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <socket.socket fd=1600, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9103), raddr=('18.167.251.121', 5672)>
2024-03-26 11:54:21,231 io_services_utils.py [line:904] INFO _AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <socket.socket fd=1600, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9103), raddr=('18.167.251.121', 5672)>
2024-03-26 11:54:21,232 io_services_utils.py [line:869] INFO Deactivating transport: state=1; <socket.socket fd=1600, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9103), raddr=('18.167.251.121', 5672)>
2024-03-26 11:54:21,232 io_services_utils.py [line:869] INFO Deactivating transport: state=1; <socket.socket fd=1600, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9103), raddr=('18.167.251.121', 5672)>
2024-03-26 11:54:21,233 connection.py [line:2017] INFO AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 11:54:21,233 connection.py [line:2017] INFO AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 11:54:21,233 connection.py [line:2086] INFO Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 11:54:21,233 connection.py [line:2086] INFO Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 11:54:21,234 io_services_utils.py [line:882] INFO Closing transport socket and unlinking: state=3; <socket.socket fd=1600, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9103), raddr=('18.167.251.121', 5672)>
2024-03-26 11:54:21,234 io_services_utils.py [line:882] INFO Closing transport socket and unlinking: state=3; <socket.socket fd=1600, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9103), raddr=('18.167.251.121', 5672)>
2024-03-26 11:54:21,235 blocking_connection.py [line:525] INFO User-initiated close: result=BlockingConnection__OnClosedArgs(connection=<SelectConnection CLOSED transport=None params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>, error=ConnectionClosedByClient: (200) 'Normal shutdown')
2024-03-26 11:54:21,235 blocking_connection.py [line:525] INFO User-initiated close: result=BlockingConnection__OnClosedArgs(connection=<SelectConnection CLOSED transport=None params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>, error=ConnectionClosedByClient: (200) 'Normal shutdown')
2024-03-26 11:54:21,795 service.py [line:57] INFO 123456-86 ===> {'tasks_id': '123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/86316e41-eb24-11ee-89e0-505a65503f86.jpg'}
2024-03-26 11:54:21,795 service.py [line:57] INFO 123456-86 ===> {'tasks_id': '123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/86316e41-eb24-11ee-89e0-505a65503f86.jpg'}
2024-03-26 11:54:21,904 service.py [line:57] INFO 123456-86 ===> {'tasks_id': '123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/86316e41-eb24-11ee-89e0-505a65503f86.jpg'}
2024-03-26 11:54:21,904 service.py [line:57] INFO 123456-86 ===> {'tasks_id': '123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/86316e41-eb24-11ee-89e0-505a65503f86.jpg'}
2024-03-26 11:54:21,905 decorator.py [line:11] INFO function：【sr_result】,runtime：【10.093042850494385】s
2024-03-26 11:54:21,905 decorator.py [line:11] INFO function：【sr_result】,runtime：【10.093042850494385】s
2024-03-26 11:56:04,915 decorator.py [line:11] INFO function：【read_image】,runtime：【0.589684009552002】s
2024-03-26 11:56:04,915 decorator.py [line:11] INFO function：【read_image】,runtime：【0.589684009552002】s
2024-03-26 11:56:05,026 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:56:05,026 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:56:05,136 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:56:05,136 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:56:06,257 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:56:06,257 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:56:06,366 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:56:06,366 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:56:07,489 connection_workflow.py [line:179] INFO Pika version 1.3.2 connecting to ('18.167.251.121', 5672)
2024-03-26 11:56:07,489 connection_workflow.py [line:179] INFO Pika version 1.3.2 connecting to ('18.167.251.121', 5672)
2024-03-26 11:56:07,490 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:56:07,490 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:56:07,599 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:56:07,599 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:56:07,602 io_services_utils.py [line:345] INFO Socket connected: <socket.socket fd=1928, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9125), raddr=('18.167.251.121', 5672)>
2024-03-26 11:56:07,602 io_services_utils.py [line:345] INFO Socket connected: <socket.socket fd=1928, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9125), raddr=('18.167.251.121', 5672)>
2024-03-26 11:56:07,604 connection_workflow.py [line:428] INFO Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>).
2024-03-26 11:56:07,604 connection_workflow.py [line:428] INFO Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>).
2024-03-26 11:56:07,945 connection_workflow.py [line:293] INFO AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:56:07,945 connection_workflow.py [line:293] INFO AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:56:07,946 connection_workflow.py [line:725] INFO AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:56:07,946 connection_workflow.py [line:725] INFO AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:56:07,947 blocking_connection.py [line:453] INFO Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:56:07,947 blocking_connection.py [line:453] INFO Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:56:07,948 blocking_connection.py [line:1264] INFO Created channel=1
2024-03-26 11:56:07,948 blocking_connection.py [line:1264] INFO Created channel=1
2024-03-26 11:56:08,062 service.py [line:140] INFO [x] Sent {"tasks_id": "test123456-86", "status": "SUCCESS", "message": "success", "data": "test/c63f3d38-eb24-11ee-bf5e-505a65503f86.jpg"}
2024-03-26 11:56:08,062 service.py [line:140] INFO [x] Sent {"tasks_id": "test123456-86", "status": "SUCCESS", "message": "success", "data": "test/c63f3d38-eb24-11ee-bf5e-505a65503f86.jpg"}
2024-03-26 11:56:08,063 blocking_connection.py [line:802] INFO Closing connection (200): Normal shutdown
2024-03-26 11:56:08,063 blocking_connection.py [line:802] INFO Closing connection (200): Normal shutdown
2024-03-26 11:56:08,064 channel.py [line:536] INFO Closing channel (200): 'Normal shutdown' on <Channel number=1 OPEN conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 11:56:08,064 channel.py [line:536] INFO Closing channel (200): 'Normal shutdown' on <Channel number=1 OPEN conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 11:56:08,177 channel.py [line:1133] INFO Received <Channel.CloseOk> on <Channel number=1 CLOSING conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 11:56:08,177 channel.py [line:1133] INFO Received <Channel.CloseOk> on <Channel number=1 CLOSING conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222D8B0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 11:56:08,179 connection.py [line:1316] INFO Closing connection (200): 'Normal shutdown'
2024-03-26 11:56:08,179 connection.py [line:1316] INFO Closing connection (200): 'Normal shutdown'
2024-03-26 11:56:08,301 io_services_utils.py [line:731] INFO Aborting transport connection: state=1; <socket.socket fd=1928, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9125), raddr=('18.167.251.121', 5672)>
2024-03-26 11:56:08,301 io_services_utils.py [line:731] INFO Aborting transport connection: state=1; <socket.socket fd=1928, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9125), raddr=('18.167.251.121', 5672)>
2024-03-26 11:56:08,302 io_services_utils.py [line:904] INFO _AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <socket.socket fd=1928, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9125), raddr=('18.167.251.121', 5672)>
2024-03-26 11:56:08,302 io_services_utils.py [line:904] INFO _AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <socket.socket fd=1928, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9125), raddr=('18.167.251.121', 5672)>
2024-03-26 11:56:08,304 io_services_utils.py [line:869] INFO Deactivating transport: state=1; <socket.socket fd=1928, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9125), raddr=('18.167.251.121', 5672)>
2024-03-26 11:56:08,304 io_services_utils.py [line:869] INFO Deactivating transport: state=1; <socket.socket fd=1928, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9125), raddr=('18.167.251.121', 5672)>
2024-03-26 11:56:08,305 connection.py [line:2017] INFO AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 11:56:08,305 connection.py [line:2017] INFO AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 11:56:08,306 connection.py [line:2086] INFO Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 11:56:08,306 connection.py [line:2086] INFO Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 11:56:08,307 io_services_utils.py [line:882] INFO Closing transport socket and unlinking: state=3; <socket.socket fd=1928, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9125), raddr=('18.167.251.121', 5672)>
2024-03-26 11:56:08,307 io_services_utils.py [line:882] INFO Closing transport socket and unlinking: state=3; <socket.socket fd=1928, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9125), raddr=('18.167.251.121', 5672)>
2024-03-26 11:56:08,308 blocking_connection.py [line:525] INFO User-initiated close: result=BlockingConnection__OnClosedArgs(connection=<SelectConnection CLOSED transport=None params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>, error=ConnectionClosedByClient: (200) 'Normal shutdown')
2024-03-26 11:56:08,308 blocking_connection.py [line:525] INFO User-initiated close: result=BlockingConnection__OnClosedArgs(connection=<SelectConnection CLOSED transport=None params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>, error=ConnectionClosedByClient: (200) 'Normal shutdown')
2024-03-26 11:56:08,711 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/c63f3d38-eb24-11ee-bf5e-505a65503f86.jpg'}
2024-03-26 11:56:08,711 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/c63f3d38-eb24-11ee-bf5e-505a65503f86.jpg'}
2024-03-26 11:56:08,821 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/c63f3d38-eb24-11ee-bf5e-505a65503f86.jpg'}
2024-03-26 11:56:08,821 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/c63f3d38-eb24-11ee-bf5e-505a65503f86.jpg'}
2024-03-26 11:56:08,822 decorator.py [line:11] INFO function：【sr_result】,runtime：【4.496444463729858】s
2024-03-26 11:56:08,822 decorator.py [line:11] INFO function：【sr_result】,runtime：【4.496444463729858】s
2024-03-26 11:58:02,618 decorator.py [line:11] INFO function：【read_image】,runtime：【0.5825369358062744】s
2024-03-26 11:58:02,618 decorator.py [line:11] INFO function：【read_image】,runtime：【0.5825369358062744】s
2024-03-26 11:58:02,729 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:58:02,729 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:58:02,847 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:58:02,847 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:58:03,963 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:58:03,963 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:58:04,072 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:58:04,072 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:58:05,138 connection_workflow.py [line:179] INFO Pika version 1.3.2 connecting to ('18.167.251.121', 5672)
2024-03-26 11:58:05,138 connection_workflow.py [line:179] INFO Pika version 1.3.2 connecting to ('18.167.251.121', 5672)
2024-03-26 11:58:05,196 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:58:05,196 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:58:05,244 io_services_utils.py [line:345] INFO Socket connected: <socket.socket fd=2000, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9151), raddr=('18.167.251.121', 5672)>
2024-03-26 11:58:05,244 io_services_utils.py [line:345] INFO Socket connected: <socket.socket fd=2000, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9151), raddr=('18.167.251.121', 5672)>
2024-03-26 11:58:05,246 connection_workflow.py [line:428] INFO Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>).
2024-03-26 11:58:05,246 connection_workflow.py [line:428] INFO Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>).
2024-03-26 11:58:05,304 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:58:05,304 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 11:58:05,564 connection_workflow.py [line:293] INFO AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:58:05,564 connection_workflow.py [line:293] INFO AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:58:05,565 connection_workflow.py [line:725] INFO AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:58:05,565 connection_workflow.py [line:725] INFO AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:58:05,566 blocking_connection.py [line:453] INFO Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:58:05,566 blocking_connection.py [line:453] INFO Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 11:58:05,567 blocking_connection.py [line:1264] INFO Created channel=1
2024-03-26 11:58:05,567 blocking_connection.py [line:1264] INFO Created channel=1
2024-03-26 11:58:05,673 service.py [line:140] INFO [x] Sent {"tasks_id": "test123456-86", "status": "SUCCESS", "message": "success", "data": "test/0c60e41b-eb25-11ee-8d62-505a65503f86.jpg"}
2024-03-26 11:58:05,673 service.py [line:140] INFO [x] Sent {"tasks_id": "test123456-86", "status": "SUCCESS", "message": "success", "data": "test/0c60e41b-eb25-11ee-8d62-505a65503f86.jpg"}
2024-03-26 11:58:05,674 blocking_connection.py [line:802] INFO Closing connection (200): Normal shutdown
2024-03-26 11:58:05,674 blocking_connection.py [line:802] INFO Closing connection (200): Normal shutdown
2024-03-26 11:58:05,676 channel.py [line:536] INFO Closing channel (200): 'Normal shutdown' on <Channel number=1 OPEN conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 11:58:05,676 channel.py [line:536] INFO Closing channel (200): 'Normal shutdown' on <Channel number=1 OPEN conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 11:58:05,779 channel.py [line:1133] INFO Received <Channel.CloseOk> on <Channel number=1 CLOSING conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 11:58:05,779 channel.py [line:1133] INFO Received <Channel.CloseOk> on <Channel number=1 CLOSING conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222FD60> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 11:58:05,781 connection.py [line:1316] INFO Closing connection (200): 'Normal shutdown'
2024-03-26 11:58:05,781 connection.py [line:1316] INFO Closing connection (200): 'Normal shutdown'
2024-03-26 11:58:05,886 io_services_utils.py [line:731] INFO Aborting transport connection: state=1; <socket.socket fd=2000, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9151), raddr=('18.167.251.121', 5672)>
2024-03-26 11:58:05,886 io_services_utils.py [line:731] INFO Aborting transport connection: state=1; <socket.socket fd=2000, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9151), raddr=('18.167.251.121', 5672)>
2024-03-26 11:58:05,886 io_services_utils.py [line:904] INFO _AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <socket.socket fd=2000, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9151), raddr=('18.167.251.121', 5672)>
2024-03-26 11:58:05,886 io_services_utils.py [line:904] INFO _AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <socket.socket fd=2000, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9151), raddr=('18.167.251.121', 5672)>
2024-03-26 11:58:05,888 io_services_utils.py [line:869] INFO Deactivating transport: state=1; <socket.socket fd=2000, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9151), raddr=('18.167.251.121', 5672)>
2024-03-26 11:58:05,888 io_services_utils.py [line:869] INFO Deactivating transport: state=1; <socket.socket fd=2000, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9151), raddr=('18.167.251.121', 5672)>
2024-03-26 11:58:05,889 connection.py [line:2017] INFO AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 11:58:05,889 connection.py [line:2017] INFO AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 11:58:05,889 connection.py [line:2086] INFO Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 11:58:05,889 connection.py [line:2086] INFO Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 11:58:05,890 io_services_utils.py [line:882] INFO Closing transport socket and unlinking: state=3; <socket.socket fd=2000, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9151), raddr=('18.167.251.121', 5672)>
2024-03-26 11:58:05,890 io_services_utils.py [line:882] INFO Closing transport socket and unlinking: state=3; <socket.socket fd=2000, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 9151), raddr=('18.167.251.121', 5672)>
2024-03-26 11:58:05,891 blocking_connection.py [line:525] INFO User-initiated close: result=BlockingConnection__OnClosedArgs(connection=<SelectConnection CLOSED transport=None params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>, error=ConnectionClosedByClient: (200) 'Normal shutdown')
2024-03-26 11:58:05,891 blocking_connection.py [line:525] INFO User-initiated close: result=BlockingConnection__OnClosedArgs(connection=<SelectConnection CLOSED transport=None params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>, error=ConnectionClosedByClient: (200) 'Normal shutdown')
2024-03-26 11:58:06,415 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/0c60e41b-eb25-11ee-8d62-505a65503f86.jpg'}
2024-03-26 11:58:06,415 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/0c60e41b-eb25-11ee-8d62-505a65503f86.jpg'}
2024-03-26 11:58:06,525 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/0c60e41b-eb25-11ee-8d62-505a65503f86.jpg'}
2024-03-26 11:58:06,525 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/0c60e41b-eb25-11ee-8d62-505a65503f86.jpg'}
2024-03-26 11:58:06,526 decorator.py [line:11] INFO function：【sr_result】,runtime：【4.4898035526275635】s
2024-03-26 11:58:06,526 decorator.py [line:11] INFO function：【sr_result】,runtime：【4.4898035526275635】s
2024-03-26 14:04:08,737 decorator.py [line:11] INFO function：【read_image】,runtime：【0.7120976448059082】s
2024-03-26 14:04:08,737 decorator.py [line:11] INFO function：【read_image】,runtime：【0.7120976448059082】s
2024-03-26 14:04:08,852 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:04:08,852 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:04:08,961 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:04:08,961 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:04:10,074 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:04:10,074 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:04:10,183 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:04:10,183 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:04:11,252 connection_workflow.py [line:179] INFO Pika version 1.3.2 connecting to ('18.167.251.121', 5672)
2024-03-26 14:04:11,252 connection_workflow.py [line:179] INFO Pika version 1.3.2 connecting to ('18.167.251.121', 5672)
2024-03-26 14:04:11,297 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:04:11,297 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:04:11,359 io_services_utils.py [line:345] INFO Socket connected: <socket.socket fd=1904, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11252), raddr=('18.167.251.121', 5672)>
2024-03-26 14:04:11,359 io_services_utils.py [line:345] INFO Socket connected: <socket.socket fd=1904, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11252), raddr=('18.167.251.121', 5672)>
2024-03-26 14:04:11,361 connection_workflow.py [line:428] INFO Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>).
2024-03-26 14:04:11,361 connection_workflow.py [line:428] INFO Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>).
2024-03-26 14:04:11,408 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:04:11,408 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:04:11,683 connection_workflow.py [line:293] INFO AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:04:11,683 connection_workflow.py [line:293] INFO AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:04:11,684 connection_workflow.py [line:725] INFO AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:04:11,684 connection_workflow.py [line:725] INFO AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:04:11,686 blocking_connection.py [line:453] INFO Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:04:11,686 blocking_connection.py [line:453] INFO Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:04:11,687 blocking_connection.py [line:1264] INFO Created channel=1
2024-03-26 14:04:11,687 blocking_connection.py [line:1264] INFO Created channel=1
2024-03-26 14:04:11,795 service.py [line:140] INFO [x] Sent {"tasks_id": "test123456-86", "status": "SUCCESS", "message": "success", "data": "test/aa1fa6f0-eb36-11ee-ba61-505a65503f86.jpg"}
2024-03-26 14:04:11,795 service.py [line:140] INFO [x] Sent {"tasks_id": "test123456-86", "status": "SUCCESS", "message": "success", "data": "test/aa1fa6f0-eb36-11ee-ba61-505a65503f86.jpg"}
2024-03-26 14:04:11,796 blocking_connection.py [line:802] INFO Closing connection (200): Normal shutdown
2024-03-26 14:04:11,796 blocking_connection.py [line:802] INFO Closing connection (200): Normal shutdown
2024-03-26 14:04:11,796 channel.py [line:536] INFO Closing channel (200): 'Normal shutdown' on <Channel number=1 OPEN conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 14:04:11,796 channel.py [line:536] INFO Closing channel (200): 'Normal shutdown' on <Channel number=1 OPEN conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 14:04:11,903 channel.py [line:1133] INFO Received <Channel.CloseOk> on <Channel number=1 CLOSING conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 14:04:11,903 channel.py [line:1133] INFO Received <Channel.CloseOk> on <Channel number=1 CLOSING conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E222F7F0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 14:04:11,904 connection.py [line:1316] INFO Closing connection (200): 'Normal shutdown'
2024-03-26 14:04:11,904 connection.py [line:1316] INFO Closing connection (200): 'Normal shutdown'
2024-03-26 14:04:12,012 io_services_utils.py [line:731] INFO Aborting transport connection: state=1; <socket.socket fd=1904, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11252), raddr=('18.167.251.121', 5672)>
2024-03-26 14:04:12,012 io_services_utils.py [line:731] INFO Aborting transport connection: state=1; <socket.socket fd=1904, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11252), raddr=('18.167.251.121', 5672)>
2024-03-26 14:04:12,012 io_services_utils.py [line:904] INFO _AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <socket.socket fd=1904, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11252), raddr=('18.167.251.121', 5672)>
2024-03-26 14:04:12,012 io_services_utils.py [line:904] INFO _AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <socket.socket fd=1904, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11252), raddr=('18.167.251.121', 5672)>
2024-03-26 14:04:12,013 io_services_utils.py [line:869] INFO Deactivating transport: state=1; <socket.socket fd=1904, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11252), raddr=('18.167.251.121', 5672)>
2024-03-26 14:04:12,013 io_services_utils.py [line:869] INFO Deactivating transport: state=1; <socket.socket fd=1904, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11252), raddr=('18.167.251.121', 5672)>
2024-03-26 14:04:12,016 connection.py [line:2017] INFO AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 14:04:12,016 connection.py [line:2017] INFO AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 14:04:12,017 connection.py [line:2086] INFO Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 14:04:12,017 connection.py [line:2086] INFO Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 14:04:12,017 io_services_utils.py [line:882] INFO Closing transport socket and unlinking: state=3; <socket.socket fd=1904, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11252), raddr=('18.167.251.121', 5672)>
2024-03-26 14:04:12,017 io_services_utils.py [line:882] INFO Closing transport socket and unlinking: state=3; <socket.socket fd=1904, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11252), raddr=('18.167.251.121', 5672)>
2024-03-26 14:04:12,018 blocking_connection.py [line:525] INFO User-initiated close: result=BlockingConnection__OnClosedArgs(connection=<SelectConnection CLOSED transport=None params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>, error=ConnectionClosedByClient: (200) 'Normal shutdown')
2024-03-26 14:04:12,018 blocking_connection.py [line:525] INFO User-initiated close: result=BlockingConnection__OnClosedArgs(connection=<SelectConnection CLOSED transport=None params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>, error=ConnectionClosedByClient: (200) 'Normal shutdown')
2024-03-26 14:04:12,527 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/aa1fa6f0-eb36-11ee-ba61-505a65503f86.jpg'}
2024-03-26 14:04:12,527 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/aa1fa6f0-eb36-11ee-ba61-505a65503f86.jpg'}
2024-03-26 14:04:12,637 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/aa1fa6f0-eb36-11ee-ba61-505a65503f86.jpg'}
2024-03-26 14:04:12,637 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/aa1fa6f0-eb36-11ee-ba61-505a65503f86.jpg'}
2024-03-26 14:04:12,638 decorator.py [line:11] INFO function：【sr_result】,runtime：【4.612610340118408】s
2024-03-26 14:04:12,638 decorator.py [line:11] INFO function：【sr_result】,runtime：【4.612610340118408】s
2024-03-26 14:09:40,452 decorator.py [line:11] INFO function：【read_image】,runtime：【0.6648626327514648】s
2024-03-26 14:09:40,452 decorator.py [line:11] INFO function：【read_image】,runtime：【0.6648626327514648】s
2024-03-26 14:09:40,563 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:09:40,563 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:09:40,672 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:09:40,672 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:09:41,799 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:09:41,799 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:09:41,920 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:09:41,920 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:09:42,805 connection_workflow.py [line:179] INFO Pika version 1.3.2 connecting to ('18.167.251.121', 5672)
2024-03-26 14:09:42,805 connection_workflow.py [line:179] INFO Pika version 1.3.2 connecting to ('18.167.251.121', 5672)
2024-03-26 14:09:42,919 io_services_utils.py [line:345] INFO Socket connected: <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11520), raddr=('18.167.251.121', 5672)>
2024-03-26 14:09:42,919 io_services_utils.py [line:345] INFO Socket connected: <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11520), raddr=('18.167.251.121', 5672)>
2024-03-26 14:09:42,921 connection_workflow.py [line:428] INFO Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>).
2024-03-26 14:09:42,921 connection_workflow.py [line:428] INFO Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>).
2024-03-26 14:09:43,263 connection_workflow.py [line:293] INFO AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:09:43,263 connection_workflow.py [line:293] INFO AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:09:43,264 connection_workflow.py [line:725] INFO AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:09:43,264 connection_workflow.py [line:725] INFO AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:09:43,266 blocking_connection.py [line:453] INFO Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:09:43,266 blocking_connection.py [line:453] INFO Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:09:43,266 blocking_connection.py [line:1264] INFO Created channel=1
2024-03-26 14:09:43,266 blocking_connection.py [line:1264] INFO Created channel=1
2024-03-26 14:09:43,382 service.py [line:140] INFO [x] Sent {"tasks_id": "test123456-86", "status": "SUCCESS", "message": "success", "data": "test/6fc1f6bf-eb37-11ee-ae00-505a65503f86.jpg"}
2024-03-26 14:09:43,382 service.py [line:140] INFO [x] Sent {"tasks_id": "test123456-86", "status": "SUCCESS", "message": "success", "data": "test/6fc1f6bf-eb37-11ee-ae00-505a65503f86.jpg"}
2024-03-26 14:09:43,382 blocking_connection.py [line:802] INFO Closing connection (200): Normal shutdown
2024-03-26 14:09:43,382 blocking_connection.py [line:802] INFO Closing connection (200): Normal shutdown
2024-03-26 14:09:43,383 channel.py [line:536] INFO Closing channel (200): 'Normal shutdown' on <Channel number=1 OPEN conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 14:09:43,383 channel.py [line:536] INFO Closing channel (200): 'Normal shutdown' on <Channel number=1 OPEN conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 14:09:43,497 channel.py [line:1133] INFO Received <Channel.CloseOk> on <Channel number=1 CLOSING conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 14:09:43,497 channel.py [line:1133] INFO Received <Channel.CloseOk> on <Channel number=1 CLOSING conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E2018CA0> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 14:09:43,497 connection.py [line:1316] INFO Closing connection (200): 'Normal shutdown'
2024-03-26 14:09:43,497 connection.py [line:1316] INFO Closing connection (200): 'Normal shutdown'
2024-03-26 14:09:43,611 io_services_utils.py [line:731] INFO Aborting transport connection: state=1; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11520), raddr=('18.167.251.121', 5672)>
2024-03-26 14:09:43,611 io_services_utils.py [line:731] INFO Aborting transport connection: state=1; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11520), raddr=('18.167.251.121', 5672)>
2024-03-26 14:09:43,612 io_services_utils.py [line:904] INFO _AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11520), raddr=('18.167.251.121', 5672)>
2024-03-26 14:09:43,612 io_services_utils.py [line:904] INFO _AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11520), raddr=('18.167.251.121', 5672)>
2024-03-26 14:09:43,613 io_services_utils.py [line:869] INFO Deactivating transport: state=1; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11520), raddr=('18.167.251.121', 5672)>
2024-03-26 14:09:43,613 io_services_utils.py [line:869] INFO Deactivating transport: state=1; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11520), raddr=('18.167.251.121', 5672)>
2024-03-26 14:09:43,614 connection.py [line:2017] INFO AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 14:09:43,614 connection.py [line:2017] INFO AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 14:09:43,614 connection.py [line:2086] INFO Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 14:09:43,614 connection.py [line:2086] INFO Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 14:09:43,616 io_services_utils.py [line:882] INFO Closing transport socket and unlinking: state=3; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11520), raddr=('18.167.251.121', 5672)>
2024-03-26 14:09:43,616 io_services_utils.py [line:882] INFO Closing transport socket and unlinking: state=3; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11520), raddr=('18.167.251.121', 5672)>
2024-03-26 14:09:43,617 blocking_connection.py [line:525] INFO User-initiated close: result=BlockingConnection__OnClosedArgs(connection=<SelectConnection CLOSED transport=None params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>, error=ConnectionClosedByClient: (200) 'Normal shutdown')
2024-03-26 14:09:43,617 blocking_connection.py [line:525] INFO User-initiated close: result=BlockingConnection__OnClosedArgs(connection=<SelectConnection CLOSED transport=None params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>, error=ConnectionClosedByClient: (200) 'Normal shutdown')
2024-03-26 14:09:44,267 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:09:44,267 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:09:44,376 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:09:44,376 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:09:45,491 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/6fc1f6bf-eb37-11ee-ae00-505a65503f86.jpg'}
2024-03-26 14:09:45,491 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/6fc1f6bf-eb37-11ee-ae00-505a65503f86.jpg'}
2024-03-26 14:09:45,600 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/6fc1f6bf-eb37-11ee-ae00-505a65503f86.jpg'}
2024-03-26 14:09:45,600 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/6fc1f6bf-eb37-11ee-ae00-505a65503f86.jpg'}
2024-03-26 14:09:45,601 decorator.py [line:11] INFO function：【sr_result】,runtime：【5.814168691635132】s
2024-03-26 14:09:45,601 decorator.py [line:11] INFO function：【sr_result】,runtime：【5.814168691635132】s
2024-03-26 14:14:22,014 decorator.py [line:11] INFO function：【read_image】,runtime：【0.5662455558776855】s
2024-03-26 14:14:22,014 decorator.py [line:11] INFO function：【read_image】,runtime：【0.5662455558776855】s
2024-03-26 14:14:22,124 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:14:22,124 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:14:22,234 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:14:22,234 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:14:23,363 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:14:23,363 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:14:23,486 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:14:23,486 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:14:24,497 connection_workflow.py [line:179] INFO Pika version 1.3.2 connecting to ('18.167.251.121', 5672)
2024-03-26 14:14:24,497 connection_workflow.py [line:179] INFO Pika version 1.3.2 connecting to ('18.167.251.121', 5672)
2024-03-26 14:14:24,604 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:14:24,604 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:14:24,615 io_services_utils.py [line:345] INFO Socket connected: <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11631), raddr=('18.167.251.121', 5672)>
2024-03-26 14:14:24,615 io_services_utils.py [line:345] INFO Socket connected: <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11631), raddr=('18.167.251.121', 5672)>
2024-03-26 14:14:24,617 connection_workflow.py [line:428] INFO Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>).
2024-03-26 14:14:24,617 connection_workflow.py [line:428] INFO Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>).
2024-03-26 14:14:24,714 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:14:24,714 service.py [line:57] INFO test123456-86 ===> {'status': 'PENDING', 'message': 'pending', 'data': ''}
2024-03-26 14:14:24,967 connection_workflow.py [line:293] INFO AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:14:24,967 connection_workflow.py [line:293] INFO AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:14:24,969 connection_workflow.py [line:725] INFO AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:14:24,969 connection_workflow.py [line:725] INFO AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:14:24,972 blocking_connection.py [line:453] INFO Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:14:24,972 blocking_connection.py [line:453] INFO Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>
2024-03-26 14:14:24,974 blocking_connection.py [line:1264] INFO Created channel=1
2024-03-26 14:14:24,974 blocking_connection.py [line:1264] INFO Created channel=1
2024-03-26 14:14:25,092 service.py [line:140] INFO [x] Sent {"tasks_id": "test123456-86", "status": "SUCCESS", "message": "success", "data": "test/17a7c92f-eb38-11ee-babe-505a65503f86.jpg"}
2024-03-26 14:14:25,092 service.py [line:140] INFO [x] Sent {"tasks_id": "test123456-86", "status": "SUCCESS", "message": "success", "data": "test/17a7c92f-eb38-11ee-babe-505a65503f86.jpg"}
2024-03-26 14:14:25,093 blocking_connection.py [line:802] INFO Closing connection (200): Normal shutdown
2024-03-26 14:14:25,093 blocking_connection.py [line:802] INFO Closing connection (200): Normal shutdown
2024-03-26 14:14:25,094 channel.py [line:536] INFO Closing channel (200): 'Normal shutdown' on <Channel number=1 OPEN conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 14:14:25,094 channel.py [line:536] INFO Closing channel (200): 'Normal shutdown' on <Channel number=1 OPEN conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 14:14:25,210 channel.py [line:1133] INFO Received <Channel.CloseOk> on <Channel number=1 CLOSING conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 14:14:25,210 channel.py [line:1133] INFO Received <Channel.CloseOk> on <Channel number=1 CLOSING conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x00000277E223C850> params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>>
2024-03-26 14:14:25,213 connection.py [line:1316] INFO Closing connection (200): 'Normal shutdown'
2024-03-26 14:14:25,213 connection.py [line:1316] INFO Closing connection (200): 'Normal shutdown'
2024-03-26 14:14:25,328 io_services_utils.py [line:731] INFO Aborting transport connection: state=1; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11631), raddr=('18.167.251.121', 5672)>
2024-03-26 14:14:25,328 io_services_utils.py [line:731] INFO Aborting transport connection: state=1; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11631), raddr=('18.167.251.121', 5672)>
2024-03-26 14:14:25,330 io_services_utils.py [line:904] INFO _AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11631), raddr=('18.167.251.121', 5672)>
2024-03-26 14:14:25,330 io_services_utils.py [line:904] INFO _AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11631), raddr=('18.167.251.121', 5672)>
2024-03-26 14:14:25,331 io_services_utils.py [line:869] INFO Deactivating transport: state=1; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11631), raddr=('18.167.251.121', 5672)>
2024-03-26 14:14:25,331 io_services_utils.py [line:869] INFO Deactivating transport: state=1; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11631), raddr=('18.167.251.121', 5672)>
2024-03-26 14:14:25,332 connection.py [line:2017] INFO AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 14:14:25,332 connection.py [line:2017] INFO AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 14:14:25,333 connection.py [line:2086] INFO Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 14:14:25,333 connection.py [line:2086] INFO Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'
2024-03-26 14:14:25,334 io_services_utils.py [line:882] INFO Closing transport socket and unlinking: state=3; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11631), raddr=('18.167.251.121', 5672)>
2024-03-26 14:14:25,334 io_services_utils.py [line:882] INFO Closing transport socket and unlinking: state=3; <socket.socket fd=1872, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.3.62', 11631), raddr=('18.167.251.121', 5672)>
2024-03-26 14:14:25,335 blocking_connection.py [line:525] INFO User-initiated close: result=BlockingConnection__OnClosedArgs(connection=<SelectConnection CLOSED transport=None params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>, error=ConnectionClosedByClient: (200) 'Normal shutdown')
2024-03-26 14:14:25,335 blocking_connection.py [line:525] INFO User-initiated close: result=BlockingConnection__OnClosedArgs(connection=<SelectConnection CLOSED transport=None params=<ConnectionParameters host=18.167.251.121 port=5672 virtual_host=/ ssl=False>>, error=ConnectionClosedByClient: (200) 'Normal shutdown')
2024-03-26 14:14:25,827 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/17a7c92f-eb38-11ee-babe-505a65503f86.jpg'}
2024-03-26 14:14:25,827 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/17a7c92f-eb38-11ee-babe-505a65503f86.jpg'}
2024-03-26 14:14:25,935 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/17a7c92f-eb38-11ee-babe-505a65503f86.jpg'}
2024-03-26 14:14:25,935 service.py [line:57] INFO test123456-86 ===> {'tasks_id': 'test123456-86', 'status': 'SUCCESS', 'message': 'success', 'data': 'test/17a7c92f-eb38-11ee-babe-505a65503f86.jpg'}
2024-03-26 14:14:25,937 decorator.py [line:11] INFO function：【sr_result】,runtime：【4.489486932754517】s
2024-03-26 14:14:25,937 decorator.py [line:11] INFO function：【sr_result】,runtime：【4.489486932754517】s