in diabetes_regression/scoring/parallel_batchscore_copyoutput.py [0:0]
def copy_output(args):
print("Output : {}".format(args.output_path))
accounturl = "https://{}.blob.core.windows.net".format(
args.scoring_datastore
) # NOQA E501
containerclient = ContainerClient(
accounturl, args.score_container, args.scoring_datastore_key
)
destfolder = date.today().isoformat()
filetime = (
datetime.now(timezone.utc)
.time()
.isoformat("milliseconds")
.replace(":", "_")
.replace(".", "_")
) # noqa E501
destfilenameparts = args.scoring_output_filename.split(".")
destblobname = "{}/{}_{}.{}".format(
destfolder, destfilenameparts[0], filetime, destfilenameparts[1]
)
destblobclient = containerclient.get_blob_client(destblobname)
with open(
os.path.join(args.output_path, "parallel_run_step.txt"), "rb"
) as scorefile: # noqa E501
destblobclient.upload_blob(scorefile, blob_type="BlockBlob")