use

from lib.job.video2pose import Video2PoseJob

job = Video2PoseJob()
job.process(msg.message_id, task_data, consumer_id, consumer_topic, rocketmq_feedback)
                  

lib

lib 文件夹
	job 目录
每一个文件夹中都需要有_init_.py

class Video2PoseJob():
    def __init__(self, **kwargs):
        self.name = 'Video2PoseJob'
		def process(self, task_id, task_data, consumer_id:int, consumer_topic:str, feedback_callback):