Ah bddlZddlZddlZddlZddddddZdZdZd Zd Z d Z dd Z d Z e dk(rddlZdZeej dkDrej dZedenedede eZer!e eedeedexsdyedexsdyy)Nz 10.0.0.109i voicebot_clusteradminzmcube@admin123)hostportdatabaseuserpassword audio_jobsmcubez mcube@0121vGadminc tjjdit}|j }|r|d}nd}d|d}|j ||j }|j|j|S#tjj$r-}td|tjdYd}~yd}~wwxYw)N_calls 7417_callszSELECT callid, bid FROM z WHERE status = 0zError: ) mysql connectorconnect DB_CONFIGcursorexecutefetchallcloseErrorprintsysexit)bid connectionr calls_tablequerycallserrs sC:\Users\pc\OneDrive\Desktop\new development\voicebot_full_code\voicebot final copy\local2\rabbitmqsarvam\rabbit.pyget_unprocessed_callsr%s__,,9y9 ""$  E.K&K+;-7HIu!   ??  uo  sBBC%#C  Cc  tjtt}tjtj t t|}|j}|jtd|D]]\}}||d}tj|}|jdt|tjdtd |d |_|j!td y#tj"j$$r-}td |t'j(d Yd}~yd}~wwxYw)N)r virtual_host credentialsT)queuedurable)callidr) delivery_mode)exchange routing_keybody propertiesu➡️ Queued callid: z, bid: u#✅ Done queuing unprocessed calls.zError connecting to RabbitMQ: r)pikaPlainCredentials RABBITMQ_USER RABBITMQ_PASSBlockingConnectionConnectionParameters RABBITMQ_HOSTRABBITMQ_VHOSTchannel queue_declareRABBITMQ_QUEUEjsondumps basic_publishBasicPropertiesrr exceptionsAMQPConnectionErrorrr) r"r(rr;r+r message_datamessager#s r$send_to_rabbitmqrF0s%$++M=I ,,  % %"+'  $$& NDA!KFC Ljj.G  ! !*//"# "  *6('#? @!"  34 ?? . . .se45  sC5C88E#D==E__main__ru1📤 Fetching unprocessed calls for business ID: u5📤 Fetching unprocessed calls from default table...u@💡 Usage: python rabbit.py (e.g., python rabbit.py 6840)u ✅ Queued z calls for business: defaultz)No unprocessed calls found for business: )N)mysql.connectorrr3rr>rr9r=r5r6r:r%rF__name__rlenargvrr"rr$rNs   "       4&P z C 388}qhhqk A#GH EF PQ !# &E  CJ<'