1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
|
<html><body>
<style>
body, h1, h2, h3, div, span, p, pre, a {
margin: 0;
padding: 0;
border: 0;
font-weight: inherit;
font-style: inherit;
font-size: 100%;
font-family: inherit;
vertical-align: baseline;
}
body {
font-size: 13px;
padding: 1em;
}
h1 {
font-size: 26px;
margin-bottom: 1em;
}
h2 {
font-size: 24px;
margin-bottom: 1em;
}
h3 {
font-size: 20px;
margin-bottom: 1em;
margin-top: 1em;
}
pre, code {
line-height: 1.5;
font-family: Monaco, 'DejaVu Sans Mono', 'Bitstream Vera Sans Mono', 'Lucida Console', monospace;
}
pre {
margin-top: 0.5em;
}
h1, h2, h3, p {
font-family: Arial, sans serif;
}
h1, h2, h3 {
border-bottom: solid #CCC 1px;
}
.toc_element {
margin-top: 0.5em;
}
.firstline {
margin-left: 2 em;
}
.method {
margin-top: 1em;
border: solid 1px #CCC;
padding: 1em;
background: #EEE;
}
.details {
font-weight: bold;
font-size: 14px;
}
</style>
<h1><a href="connectors_v2.html">Connectors API</a> . <a href="connectors_v2.projects.html">projects</a> . <a href="connectors_v2.projects.locations.html">locations</a> . <a href="connectors_v2.projects.locations.connections.html">connections</a></h1>
<h2>Instance Methods</h2>
<p class="toc_element">
<code><a href="connectors_v2.projects.locations.connections.actions.html">actions()</a></code>
</p>
<p class="firstline">Returns the actions Resource.</p>
<p class="toc_element">
<code><a href="connectors_v2.projects.locations.connections.entityTypes.html">entityTypes()</a></code>
</p>
<p class="firstline">Returns the entityTypes Resource.</p>
<p class="toc_element">
<code><a href="connectors_v2.projects.locations.connections.tools.html">tools()</a></code>
</p>
<p class="firstline">Returns the tools Resource.</p>
<p class="toc_element">
<code><a href="#checkReadiness">checkReadiness(name, x__xgafv=None)</a></code></p>
<p class="firstline">Reports readiness status of the connector. Similar logic to GetStatus but modified for kubernetes health check to understand.</p>
<p class="toc_element">
<code><a href="#checkStatus">checkStatus(name, x__xgafv=None)</a></code></p>
<p class="firstline">Reports the status of the connection. Note that when the connection is in a state that is not ACTIVE, the implementation of this RPC method must return a Status with the corresponding State instead of returning a gRPC status code that is not "OK", which indicates that ConnectionStatus itself, not the connection, failed.</p>
<p class="toc_element">
<code><a href="#close">close()</a></code></p>
<p class="firstline">Close httplib2 connections.</p>
<p class="toc_element">
<code><a href="#exchangeAuthCode">exchangeAuthCode(name, body=None, x__xgafv=None)</a></code></p>
<p class="firstline">ExchangeAuthCode exchanges the OAuth authorization code (and other necessary data) for an access token (and associated credentials).</p>
<p class="toc_element">
<code><a href="#executeSqlQuery">executeSqlQuery(connection, body=None, x__xgafv=None)</a></code></p>
<p class="firstline">Executes a SQL statement specified in the body of the request. An example of this SQL statement in the case of Salesforce connector would be 'select * from Account a, Order o where a.Id = o.AccountId'.</p>
<p class="toc_element">
<code><a href="#refreshAccessToken">refreshAccessToken(name, body=None, x__xgafv=None)</a></code></p>
<p class="firstline">RefreshAccessToken exchanges the OAuth refresh token (and other necessary data) for a new access token (and new associated credentials).</p>
<h3>Method Details</h3>
<div class="method">
<code class="details" id="checkReadiness">checkReadiness(name, x__xgafv=None)</code>
<pre>Reports readiness status of the connector. Similar logic to GetStatus but modified for kubernetes health check to understand.
Args:
name: string, A parameter (required)
x__xgafv: string, V1 error format.
Allowed values
1 - v1 error format
2 - v2 error format
Returns:
An object of the form:
{ # Response containing status of the connector for readiness prober.
"status": "A String",
}</pre>
</div>
<div class="method">
<code class="details" id="checkStatus">checkStatus(name, x__xgafv=None)</code>
<pre>Reports the status of the connection. Note that when the connection is in a state that is not ACTIVE, the implementation of this RPC method must return a Status with the corresponding State instead of returning a gRPC status code that is not "OK", which indicates that ConnectionStatus itself, not the connection, failed.
Args:
name: string, A parameter (required)
x__xgafv: string, V1 error format.
Allowed values
1 - v1 error format
2 - v2 error format
Returns:
An object of the form:
{ # The status of the connector.
"description": "A String", # When the connector is not in ACTIVE state, the description must be populated to specify the reason why it's not in ACTIVE state.
"metadata": { # Metadata like service latency, etc.
"a_key": {
"a_key": "", # Properties of the object. Contains field @type with type URL.
},
},
"state": "A String", # State of the connector.
}</pre>
</div>
<div class="method">
<code class="details" id="close">close()</code>
<pre>Close httplib2 connections.</pre>
</div>
<div class="method">
<code class="details" id="exchangeAuthCode">exchangeAuthCode(name, body=None, x__xgafv=None)</code>
<pre>ExchangeAuthCode exchanges the OAuth authorization code (and other necessary data) for an access token (and associated credentials).
Args:
name: string, A parameter (required)
body: object, The request body.
The object takes the form of:
{ # ExchangeAuthCodeRequest currently includes the auth code data.
"authCodeData": { # AuthCodeData contains the data the runtime plane will give the connector backend in exchange for access and refresh tokens. # Optional. AuthCodeData contains the data the runtime requires to exchange for access and refresh tokens. If the data is not provided, the runtime will read the data from the secret manager.
"authCode": "A String", # OAuth authorization code.
"pkceVerifier": "A String", # OAuth PKCE verifier, needed if PKCE is enabled for this particular connection.
"redirectUri": "A String", # OAuth redirect URI passed in during the auth code flow, required by some OAuth backends.
"scopes": [ # Scopes the connection will request when the user performs the auth code flow.
"A String",
],
},
}
x__xgafv: string, V1 error format.
Allowed values
1 - v1 error format
2 - v2 error format
Returns:
An object of the form:
{ # ExchangeAuthCodeResponse includes the returned access token and its associated credentials.
"accessCredentials": { # AccessCredentials includes the OAuth access token, and the other fields returned along with it.
"accessToken": "A String", # OAuth access token.
"expiresIn": "A String", # Duration till the access token expires.
"refreshToken": "A String", # OAuth refresh token.
},
"metadata": { # Metadata like service latency, etc.
"a_key": {
"a_key": "", # Properties of the object. Contains field @type with type URL.
},
},
}</pre>
</div>
<div class="method">
<code class="details" id="executeSqlQuery">executeSqlQuery(connection, body=None, x__xgafv=None)</code>
<pre>Executes a SQL statement specified in the body of the request. An example of this SQL statement in the case of Salesforce connector would be 'select * from Account a, Order o where a.Id = o.AccountId'.
Args:
connection: string, Required. Resource name of the Connection. Format: projects/{project}/locations/{location}/connections/{connection} (required)
body: object, The request body.
The object takes the form of:
{ # An execute sql query request containing the query and the connection to execute it on.
"query": { # A wrapper around the SQL query statement. This is needed so that the JSON representation of ExecuteSqlQueryRequest has the following format: `{"query":"select *"}`. # Required. SQL statement passed by clients like Integration Platform, the query is passed as-is to the driver used for interfacing with external systems.
"maxRows": "A String", # Sets the limit for the maximum number of rows returned after the query execution.
"query": "A String", # Required. Sql query to execute.
"queryParameters": [ # In the struct, the value corresponds to the value of query parameter and date type corresponds to the date type of the query parameter.
{ # Query parameter definition
"dataType": "A String",
"value": "",
},
],
"timeout": "A String", # Sets the number of seconds the driver will wait for a query to execute.
},
}
x__xgafv: string, V1 error format.
Allowed values
1 - v1 error format
2 - v2 error format
Returns:
An object of the form:
{ # A response returned by the connection after executing the sql query.
"results": [ # In the case of successful execution of the query the response contains results returned by the external system. For example, the result rows of the query are contained in the 'results' Struct list - "results": [ { "field1": "val1", "field2": "val2",.. },.. ] Each Struct row can contain fields any type of like nested Structs or lists.
{
"a_key": "", # Properties of the object.
},
],
}</pre>
</div>
<div class="method">
<code class="details" id="refreshAccessToken">refreshAccessToken(name, body=None, x__xgafv=None)</code>
<pre>RefreshAccessToken exchanges the OAuth refresh token (and other necessary data) for a new access token (and new associated credentials).
Args:
name: string, A parameter (required)
body: object, The request body.
The object takes the form of:
{ # RefreshAccessTokenRequest includes the refresh token.
"refreshToken": "A String", # Optional. Refresh Token String. If the Refresh Token is not provided, the runtime will read the data from the secret manager.
}
x__xgafv: string, V1 error format.
Allowed values
1 - v1 error format
2 - v2 error format
Returns:
An object of the form:
{ # RefreshAccessTokenResponse includes the returned access token and its associated credentials.
"accessCredentials": { # AccessCredentials includes the OAuth access token, and the other fields returned along with it.
"accessToken": "A String", # OAuth access token.
"expiresIn": "A String", # Duration till the access token expires.
"refreshToken": "A String", # OAuth refresh token.
},
"metadata": { # Metadata like service latency, etc.
"a_key": {
"a_key": "", # Properties of the object. Contains field @type with type URL.
},
},
}</pre>
</div>
</body></html>
|
