in scripts/provisioning/command_line.py [0:0]
def main(command, project_id, start_date, source_bucket,
sink_bucket, service_name):
storage_client = storage.Client()
#service_name = 'http://david-sdrs-api.endpoints.sdrs-server.cloud.goog'
try:
bucket = storage_client.get_bucket(source_bucket)
print("Bucket exists, proceeding")
except Exception as e:
LOGGER.error("Exception, exiting program " + str(e))
sys.exit()
if command == 'create':
pooled_sts_jobs = _create_sts_jobs_for_bucket(project_id, start_date, source_bucket,
sink_bucket, 'dataset')
_register_sdrs_sts_jobs(source_bucket, project_id, pooled_sts_jobs, service_name)
elif command == 'delete':
_delete_sts_jobs_for_bucket(project_id, source_bucket, service_name)
else:
print("Unknown command " + str(command))
sys.exit()