Newer
Older
# import os
# # os.environ['CSST_PIPELINE_GRPC_SERVER']="122.96.144.152:39092"
# os.environ['CSST_PIPELINE_GRPC_SERVER']="10.255.2.11:50051"
# os.environ['CSST_ADML2_JOB_ID']="12"
# os.environ['CSST_ADML1_JOB_ID']="14"
from pyscalebox import PyScaleboxApi
#2级流水线测试代码
body="brickid,name1,name2"
PyScaleboxApi().send_message_L2(body)