o %i @sddlZddlZddlZddlZddddddZdZdZd Zd Z d Z dd d Z ddZ e dkrvddlZdZeejdkrIejdZedenedede eZerke eedeedepeddSedeppddSdS)Nz 10.0.0.109i voicebot_clusteradminzmcube@admin123)hostportdatabaseuserpassword audio_jobsmcubez mcube@0121vGadminc Csz1tjjdit}|}|r|d}nd}d|d}|||}|||WStjjyR}zt d|t dWYd}~dSd}~ww)N_calls 7987_callszSELECT callid, bid FROM z WHERE status = 0zError: ) mysql connectorconnect DB_CONFIGcursorexecutefetchallcloseErrorprintsysexit)bid connectionr calls_tablequerycallserrrr//var/www/html/sara/post call analysis/rabbit.pyget_unprocessed_callss"   r#c CszOttt}ttjtt|d}|}|j t dd|D]%\}}||d}t |}|j dt |tjdddtd |d |q|td WdStjjyp}ztd |td WYd}~dSd}~ww)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%rr8r(r message_datamessager!rrr"send_to_rabbitmq0s@   rC__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.connectorrr0rr;rr6r:r2r3r7r#rC__name__rlenargvrr rrrr"s>  (