from rocketmq.client import PushConsumer
import time

namesrv = "172.19.193.178:9876"
topic_name = 'topic_name'


def callback(msg):
    print(msg)


consumer = PushConsumer('PID-0012', message_model=0)
consumer.set_namesrv_addr(namesrv)
consumer.subscribe(topic_name, callback)
consumer.start()
while True:
    time.sleep(30)
consumer.shutdown()