MessagesV1Beta3Client

Example

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  A project id.
   */
  // const projectId = 'abc123'
  /**
   *  The job to get messages about.
   */
  // const jobId = 'abc123'
  /**
   *  Filter to only get messages with importance >= level
   */
  // const minimumImportance = {}
  /**
   *  If specified, determines the maximum number of messages to
   *  return.  If unspecified, the service may choose an appropriate
   *  default, or may return an arbitrarily large number of results.
   */
  // const pageSize = 1234
  /**
   *  If supplied, this should be the value of next_page_token returned
   *  by an earlier call. This will cause the next page of results to
   *  be returned.
   */
  // const pageToken = 'abc123'
  /**
   *  If specified, return only messages with timestamps >= start_time.
   *  The default is the job creation time (i.e. beginning of messages).
   */
  // const startTime = {}
  /**
   *  Return only messages with timestamps < end_time. The default is now
   *  (i.e. return up to the latest messages available).
   */
  // const endTime = {}
  /**
   *  The regional endpoint 
   *  (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) that
   *  contains the job specified by job_id.
   */
  // const location = 'abc123'

  // Imports the Dataflow library
  const {MessagesV1Beta3Client} = require('@google-cloud/dataflow').v1beta3;

  // Instantiates a client
  const dataflowClient = new MessagesV1Beta3Client();

  async function callListJobMessages() {
    // Construct request
    const request = {
    };

    // Run request
    const iterable = await dataflowClient.listJobMessagesAsync(request);
    for await (const response of iterable) {
        console.log(response);
    }
  }

  callListJobMessages();