hP zSSKrSSKrSSKrSSKrSSSSSS.rSrSrSS jrS r \ S :XaSSKrSr \ "\R5S :a\RS r \"S \ 35 O\"S5 \"S5 \"\ 5r\(a&\ "\5 \"S\ "\5S\ =(d S35 g\"S\ =(d S35 gg)Nz 10.0.0.204i voicebot_clusterrootzmcube@admin123)hostportdatabaseuserpassword audio_jobsc[RR"S0[D6nUR 5nU(aUS3nOSnSUS3nUR U5 UR 5nUR5 UR5 U$![RRa.n[SU35 [R"S5 SnAgSnAff=f)N_calls 7417_callszSELECT callid, bid FROM z WHERE status = 0zError: ) mysql connectorconnect DB_CONFIGcursorexecutefetchallcloseErrorprintsysexit)bid connectionr calls_tablequerycallserrs BC:\Users\pc\OneDrive\Desktop\rabbitasrvam\rabbitmqsarvam\rabbit.pyget_unprocessed_callsr#s__,,9y9 ""$  E.K&K+;-7HIu!   ??  uo  sB BC,$CCc 8[R"[R"[S95nUR 5nUR [ SS9 UHYup4UUS.n[R"U5nURS[ U[R"SS9S9 [S US U35 M[ UR5 [S 5 g![RRa.n[S U35 [R "S 5 SnAgSnAff=f)N)rT)queuedurable)callidr) delivery_mode)exchange routing_keybody propertiesu➡️ Queued callid: z, bid: u#✅ Done queuing unprocessed calls.zError connecting to RabbitMQ: r)pikaBlockingConnectionConnectionParameters RABBITMQ_HOSTchannel queue_declareRABBITMQ_QUEUEjsondumps basic_publishBasicPropertiesrr exceptionsAMQPConnectionErrorrr)r rr3r'r message_datamessager!s r"send_to_rabbitmqr>-s,,T-F-FM-Z[ $$& NDA!KF Ljj.G  ! !*//"# "  *6('#? @!"  34 ?? . . .se45  sC C D+$DD__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.connectorrr/rr6rr2r5r#r>__name__rlenargvrr rr"rFs   "     4B z C 388}qhhqk A#GH EF PQ !# &E  CJ<'