Function main

batch/simple/simple.cc:20–73

#include <iostream>

int main(int argc, char* argv[]) try {
  if (argc != 5) {
    std::cerr << "Usage: " << argv[0]
              << " <project-id> <region-id> <job-id> <job-json-file>\n";
    return 1;
  }

  namespace batch = ::google::cloud::batch_v1;

  std::string const project_id = argv[1];
  auto const location = google::cloud::Location(argv[1], argv[2]);
  std::string const job_id = argv[3];
  std::string const job_file = argv[4];

  // Parse the json and convert into protobuf format.
  std::ifstream file(job_file, std::ios::in);
  if (!file.is_open()) {
    std::cout << "Failed to open JSON file: " << job_file << '\n';
    return 0;
  }
  auto contents = std::string{std::istreambuf_iterator<char>(file), {}};
  google::cloud::batch::v1::Job job;
  google::protobuf::util::JsonParseOptions options;
  google::protobuf::util::Status status =
      google::protobuf::util::JsonStringToMessage(contents, &job, options);
  if (!status.ok()) throw status;

  // Create the cloud batch client.
  auto client = batch::BatchServiceClient(batch::MakeBatchServiceConnection());

  // Create a job.
  auto response = client.CreateJob(location.FullName(), job, job_id);

  if (!response) {
    if (response.status().code() ==
        google::cloud::StatusCode::kResourceExhausted) {
      std::cout << "There already exists a job for the parent `"
                << location.FullName() << "` and job_id: `" << job_id
                << "`. Please try again with a new job id.\n";
      return 0;
    }
    throw std::move(response).status();
  }

  // On success, print the job.
  std::cout << "Job : " << response->DebugString() << "\n";
  return 0;
} catch (google::cloud::Status const& status) {
  std::cerr << "google::cloud::Status thrown: " << status << "\n";
  return 1;
} catch (google::protobuf::util::Status const& status) {
  std::cerr << "google::protobuf::util::Status thrown: " << status << "\n";
  return 1;
}