blob: f00d95f445644707c256bd2092d29280cde5ef3d [file] [log] [blame]
Nathaniel Manista4f877e52015-06-15 16:44:50 +00001<html><body>
2<style>
3
4body, h1, h2, h3, div, span, p, pre, a {
5 margin: 0;
6 padding: 0;
7 border: 0;
8 font-weight: inherit;
9 font-style: inherit;
10 font-size: 100%;
11 font-family: inherit;
12 vertical-align: baseline;
13}
14
15body {
16 font-size: 13px;
17 padding: 1em;
18}
19
20h1 {
21 font-size: 26px;
22 margin-bottom: 1em;
23}
24
25h2 {
26 font-size: 24px;
27 margin-bottom: 1em;
28}
29
30h3 {
31 font-size: 20px;
32 margin-bottom: 1em;
33 margin-top: 1em;
34}
35
36pre, code {
37 line-height: 1.5;
38 font-family: Monaco, 'DejaVu Sans Mono', 'Bitstream Vera Sans Mono', 'Lucida Console', monospace;
39}
40
41pre {
42 margin-top: 0.5em;
43}
44
45h1, h2, h3, p {
46 font-family: Arial, sans serif;
47}
48
49h1, h2, h3 {
50 border-bottom: solid #CCC 1px;
51}
52
53.toc_element {
54 margin-top: 0.5em;
55}
56
57.firstline {
58 margin-left: 2 em;
59}
60
61.method {
62 margin-top: 1em;
63 border: solid 1px #CCC;
64 padding: 1em;
65 background: #EEE;
66}
67
68.details {
69 font-weight: bold;
70 font-size: 14px;
71}
72
73</style>
74
Bu Sun Kim715bd7f2019-06-14 16:50:42 -070075<h1><a href="dataflow_v1b3.html">Dataflow API</a> . <a href="dataflow_v1b3.projects.html">projects</a></h1>
Nathaniel Manista4f877e52015-06-15 16:44:50 +000076<h2>Instance Methods</h2>
77<p class="toc_element">
Bu Sun Kim4ed7d3f2020-05-27 12:20:54 -070078 <code><a href="dataflow_v1b3.projects.catalogTemplates.html">catalogTemplates()</a></code>
79</p>
80<p class="firstline">Returns the catalogTemplates Resource.</p>
81
82<p class="toc_element">
Nathaniel Manista4f877e52015-06-15 16:44:50 +000083 <code><a href="dataflow_v1b3.projects.jobs.html">jobs()</a></code>
84</p>
85<p class="firstline">Returns the jobs Resource.</p>
86
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -080087<p class="toc_element">
Jon Wayne Parrott692617a2017-01-06 09:58:29 -080088 <code><a href="dataflow_v1b3.projects.locations.html">locations()</a></code>
89</p>
90<p class="firstline">Returns the locations Resource.</p>
91
92<p class="toc_element">
Bu Sun Kim715bd7f2019-06-14 16:50:42 -070093 <code><a href="dataflow_v1b3.projects.snapshots.html">snapshots()</a></code>
94</p>
95<p class="firstline">Returns the snapshots Resource.</p>
96
97<p class="toc_element">
Bu Sun Kim4ed7d3f2020-05-27 12:20:54 -070098 <code><a href="dataflow_v1b3.projects.templateVersions.html">templateVersions()</a></code>
99</p>
100<p class="firstline">Returns the templateVersions Resource.</p>
101
102<p class="toc_element">
Jon Wayne Parrott7d5badb2016-08-16 12:44:29 -0700103 <code><a href="dataflow_v1b3.projects.templates.html">templates()</a></code>
104</p>
105<p class="firstline">Returns the templates Resource.</p>
106
107<p class="toc_element">
Bu Sun Kim4ed7d3f2020-05-27 12:20:54 -0700108 <code><a href="#deleteSnapshots">deleteSnapshots(projectId, location=None, snapshotId=None, x__xgafv=None)</a></code></p>
Bu Sun Kim715bd7f2019-06-14 16:50:42 -0700109<p class="firstline">Deletes a snapshot.</p>
110<p class="toc_element">
Dan O'Mearadd494642020-05-01 07:42:23 -0700111 <code><a href="#workerMessages">workerMessages(projectId, body=None, x__xgafv=None)</a></code></p>
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800112<p class="firstline">Send a worker_message to the service.</p>
113<h3>Method Details</h3>
114<div class="method">
Bu Sun Kim4ed7d3f2020-05-27 12:20:54 -0700115 <code class="details" id="deleteSnapshots">deleteSnapshots(projectId, location=None, snapshotId=None, x__xgafv=None)</code>
Bu Sun Kim715bd7f2019-06-14 16:50:42 -0700116 <pre>Deletes a snapshot.
117
118Args:
119 projectId: string, The ID of the Cloud Platform project that the snapshot belongs to. (required)
Bu Sun Kim65020912020-05-20 12:08:20 -0700120 location: string, The location that contains this snapshot.
Bu Sun Kim4ed7d3f2020-05-27 12:20:54 -0700121 snapshotId: string, The ID of the snapshot.
Bu Sun Kim715bd7f2019-06-14 16:50:42 -0700122 x__xgafv: string, V1 error format.
123 Allowed values
124 1 - v1 error format
125 2 - v2 error format
126
127Returns:
128 An object of the form:
129
130 { # Response from deleting a snapshot.
131 }</pre>
132</div>
133
134<div class="method">
Dan O'Mearadd494642020-05-01 07:42:23 -0700135 <code class="details" id="workerMessages">workerMessages(projectId, body=None, x__xgafv=None)</code>
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800136 <pre>Send a worker_message to the service.
137
138Args:
139 projectId: string, The project to send the WorkerMessages to. (required)
Dan O'Mearadd494642020-05-01 07:42:23 -0700140 body: object, The request body.
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800141 The object takes the form of:
142
143{ # A request for sending worker messages to the service.
Bu Sun Kim65020912020-05-20 12:08:20 -0700144 &quot;location&quot;: &quot;A String&quot;, # The [regional endpoint]
145 # (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) that
146 # contains the job.
147 &quot;workerMessages&quot;: [ # The WorkerMessages to send.
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800148 { # WorkerMessage provides information to the backend about a worker.
Bu Sun Kim65020912020-05-20 12:08:20 -0700149 &quot;workerMetrics&quot;: { # Worker metrics exported from workers. This contains resource utilization # Resource metrics reported by workers.
150 # metrics accumulated from a variety of sources. For more information, see
151 # go/df-resource-signals.
Bu Sun Kim65020912020-05-20 12:08:20 -0700152 &quot;containers&quot;: { # Per container information.
153 # Key: container name.
154 &quot;a_key&quot;: # Object with schema name: ResourceUtilizationReport
155 },
Bu Sun Kim4ed7d3f2020-05-27 12:20:54 -0700156 &quot;memoryInfo&quot;: [ # Memory utilization samples.
157 { # Information about the memory usage of a worker or a container within a
158 # worker.
159 &quot;timestamp&quot;: &quot;A String&quot;, # Timestamp of the measurement.
160 &quot;currentLimitBytes&quot;: &quot;A String&quot;, # Instantenous memory limit in bytes.
161 &quot;currentRssBytes&quot;: &quot;A String&quot;, # Instantenous memory (RSS) size in bytes.
162 &quot;totalGbMs&quot;: &quot;A String&quot;, # Total memory (RSS) usage since start up in GB * ms.
163 },
164 ],
Bu Sun Kim65020912020-05-20 12:08:20 -0700165 &quot;cpuTime&quot;: [ # CPU utilization samples.
166 { # Modeled after information exposed by /proc/stat.
Bu Sun Kim65020912020-05-20 12:08:20 -0700167 &quot;rate&quot;: 3.14, # Average CPU utilization rate (% non-idle cpu / second) since previous
168 # sample.
169 &quot;timestamp&quot;: &quot;A String&quot;, # Timestamp of the measurement.
Bu Sun Kim4ed7d3f2020-05-27 12:20:54 -0700170 &quot;totalMs&quot;: &quot;A String&quot;, # Total active CPU time across all cores (ie., non-idle) in milliseconds
171 # since start-up.
Bu Sun Kim65020912020-05-20 12:08:20 -0700172 },
173 ],
174 },
175 &quot;workerMessageCode&quot;: { # A message code is used to report status and error messages to the service. # A worker message code.
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400176 # The message codes are intended to be machine readable. The service will
177 # take care of translating these into user understandable messages if
178 # necessary.
179 #
180 # Example use cases:
181 # 1. Worker processes reporting successful startup.
182 # 2. Worker processes reporting specific errors (e.g. package staging
183 # failure).
Bu Sun Kim4ed7d3f2020-05-27 12:20:54 -0700184 &quot;code&quot;: &quot;A String&quot;, # The code is a string intended for consumption by a machine that identifies
185 # the type of message being sent.
186 # Examples:
187 # 1. &quot;HARNESS_STARTED&quot; might be used to indicate the worker harness has
188 # started.
189 # 2. &quot;GCS_DOWNLOAD_ERROR&quot; might be used to indicate an error downloading
190 # a GCS file as part of the boot process of one of the worker containers.
191 #
192 # This is a string and not an enum to make it easy to add new codes without
193 # waiting for an API change.
Bu Sun Kim65020912020-05-20 12:08:20 -0700194 &quot;parameters&quot;: { # Parameters contains specific information about the code.
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400195 #
196 # This is a struct to allow parameters of different types.
197 #
198 # Examples:
Bu Sun Kim65020912020-05-20 12:08:20 -0700199 # 1. For a &quot;HARNESS_STARTED&quot; message parameters might provide the name
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400200 # of the worker and additional data like timing information.
Bu Sun Kim65020912020-05-20 12:08:20 -0700201 # 2. For a &quot;GCS_DOWNLOAD_ERROR&quot; parameters might contain fields listing
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400202 # the GCS objects being downloaded and fields containing errors.
203 #
204 # In general complex data structures should be avoided. If a worker
205 # needs to send a specific and complicated data structure then please
206 # consider defining a new proto and adding it to the data oneof in
207 # WorkerMessageResponse.
208 #
209 # Conventions:
Bu Sun Kim65020912020-05-20 12:08:20 -0700210 # Parameters should only be used for information that isn&#x27;t typically passed
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400211 # as a label.
212 # hostname and other worker identifiers should almost always be passed
213 # as labels since they will be included on most messages.
Bu Sun Kim65020912020-05-20 12:08:20 -0700214 &quot;a_key&quot;: &quot;&quot;, # Properties of the object.
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800215 },
Bu Sun Kim4ed7d3f2020-05-27 12:20:54 -0700216 },
217 &quot;labels&quot;: { # Labels are used to group WorkerMessages.
218 # For example, a worker_message about a particular container
219 # might have the labels:
220 # { &quot;JOB_ID&quot;: &quot;2015-04-22&quot;,
221 # &quot;WORKER_ID&quot;: &quot;wordcount-vm-2015…&quot;
222 # &quot;CONTAINER_TYPE&quot;: &quot;worker&quot;,
223 # &quot;CONTAINER_ID&quot;: &quot;ac1234def&quot;}
224 # Label tags typically correspond to Label enum values. However, for ease
225 # of development other strings can be used as tags. LABEL_UNSPECIFIED should
226 # not be used here.
227 &quot;a_key&quot;: &quot;A String&quot;,
228 },
229 &quot;time&quot;: &quot;A String&quot;, # The timestamp of the worker_message.
230 &quot;workerLifecycleEvent&quot;: { # A report of an event in a worker&#x27;s lifecycle. # Record of worker lifecycle events.
231 # The proto contains one event, because the worker is expected to
232 # asynchronously send each message immediately after the event.
233 # Due to this asynchrony, messages may arrive out of order (or missing), and it
234 # is up to the consumer to interpret.
235 # The timestamp of the event is in the enclosing WorkerMessage proto.
236 &quot;containerStartTime&quot;: &quot;A String&quot;, # The start time of this container. All events will report this so that
237 # events can be grouped together across container/VM restarts.
238 &quot;event&quot;: &quot;A String&quot;, # The event being reported.
239 &quot;metadata&quot;: { # Other stats that can accompany an event. E.g.
240 # { &quot;downloaded_bytes&quot; : &quot;123456&quot; }
241 &quot;a_key&quot;: &quot;A String&quot;,
242 },
243 },
244 &quot;workerShutdownNotice&quot;: { # Shutdown notification from workers. This is to be sent by the shutdown # Shutdown notice by workers.
245 # script of the worker VM so that the backend knows that the VM is being
246 # shut down.
247 &quot;reason&quot;: &quot;A String&quot;, # The reason for the worker shutdown.
248 # Current possible values are:
249 # &quot;UNKNOWN&quot;: shutdown reason is unknown.
250 # &quot;PREEMPTION&quot;: shutdown reason is preemption.
251 # Other possible reasons may be added in the future.
252 },
253 &quot;workerHealthReport&quot;: { # WorkerHealthReport contains information about the health of a worker. # The health of a worker.
254 #
255 # The VM should be identified by the labels attached to the WorkerMessage that
256 # this health ping belongs to.
257 &quot;pods&quot;: [ # The pods running on the worker. See:
258 # http://kubernetes.io/v1.1/docs/api-reference/v1/definitions.html#_v1_pod
Bu Sun Kim715bd7f2019-06-14 16:50:42 -0700259 #
Bu Sun Kim4ed7d3f2020-05-27 12:20:54 -0700260 # This field is used by the worker to send the status of the indvidual
261 # containers running on each worker.
262 {
263 &quot;a_key&quot;: &quot;&quot;, # Properties of the object.
264 },
265 ],
266 &quot;reportInterval&quot;: &quot;A String&quot;, # The interval at which the worker is sending health reports.
267 # The default value of 0 should be interpreted as the field is not being
268 # explicitly set by the worker.
269 &quot;vmIsHealthy&quot;: True or False, # Whether the VM is currently healthy.
270 &quot;vmIsBroken&quot;: True or False, # Whether the VM is in a permanently broken state.
271 # Broken VMs should be abandoned or deleted ASAP to avoid assigning or
272 # completing any work.
273 &quot;vmStartupTime&quot;: &quot;A String&quot;, # The time the VM was booted.
274 &quot;msg&quot;: &quot;A String&quot;, # A message describing any unusual health reports.
Bu Sun Kim715bd7f2019-06-14 16:50:42 -0700275 },
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800276 },
277 ],
278 }
279
280 x__xgafv: string, V1 error format.
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400281 Allowed values
282 1 - v1 error format
283 2 - v2 error format
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800284
285Returns:
286 An object of the form:
287
288 { # The response to the worker messages.
Bu Sun Kim65020912020-05-20 12:08:20 -0700289 &quot;workerMessageResponses&quot;: [ # The servers response to the worker messages.
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400290 { # A worker_message response allows the server to pass information to the
291 # sender.
Bu Sun Kim65020912020-05-20 12:08:20 -0700292 &quot;workerHealthReportResponse&quot;: { # WorkerHealthReportResponse contains information returned to the worker # The service&#x27;s response to a worker&#x27;s health report.
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400293 # in response to a health ping.
Bu Sun Kim65020912020-05-20 12:08:20 -0700294 &quot;reportInterval&quot;: &quot;A String&quot;, # A positive value indicates the worker should change its reporting interval
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400295 # to the specified value.
296 #
297 # The default value of zero means no change in report rate is requested by
298 # the server.
299 },
Bu Sun Kim4ed7d3f2020-05-27 12:20:54 -0700300 &quot;workerShutdownNoticeResponse&quot;: { # Service-side response to WorkerMessage issuing shutdown notice. # Service&#x27;s response to shutdown notice (currently empty).
301 },
302 &quot;workerMetricsResponse&quot;: { # Service-side response to WorkerMessage reporting resource utilization. # Service&#x27;s response to reporting worker metrics (currently empty).
303 },
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800304 },
305 ],
306 }</pre>
307</div>
308
Nathaniel Manista4f877e52015-06-15 16:44:50 +0000309</body></html>