# 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)
