Solution
from pika import BlockingConnection
connection = BlockingConnection(*args, **kwargs)
connection._heartbeat_checker._send_heartbeat()
from pika import frame
connection._send_frame(frame.Heartbeat())
from pika import BlockingConnection
connection = BlockingConnection(*args, **kwargs)
connection._heartbeat_checker._send_heartbeat()
from pika import frame
connection._send_frame(frame.Heartbeat())