# import os
# os.environ['CSST_PIPELINE_GRPC_SERVER']="122.96.144.152:39092"
# os.environ['CSST_ADML1_JOB_ID']="1"

#一级流水线测试代码
from pyscalebox import PyScaleboxApi
body="obsid,module1"
PyScaleboxApi().send_message_L1(body)