@@ -23,25 +23,10 @@ Ensure you have:
23
23
Once you have all the prerequisites in place, follow these steps to implement the Processing Engine for your data automation needs.
24
24
25
25
- [ Set up the Processing Engine] ( #set-up-the-processing-engine )
26
- - [ Configure distributed environments] ( #configure-distributed-environments )
27
26
- [ Add a Processing Engine plugin] ( #add-a-processing-engine-plugin )
28
- - [ Choose a plugin strategy] ( #choose-a-plugin-strategy )
29
- - [ Use example plugins] ( #use-example-plugins )
30
- - [ Create a custom plugin] ( #create-a-custom-plugin )
31
27
- [ Set up a trigger] ( #set-up-a-trigger )
32
- - [ Understand trigger types] ( #understand-trigger-types )
33
- - [ Use the create trigger command] ( #use-the-create-trigger-command )
34
- - [ Trigger specification examples] ( #trigger-specification-examples )
35
- - [ Pass arguments to plugins] ( #pass-arguments-to-plugins )
36
- - [ Control trigger execution] ( #control-trigger-execution )
37
- - [ Configure error handling for a trigger] ( #configure-error-handling-for-a-trigger )
38
28
- [ Advanced trigger configuration] ( #advanced-trigger-configuration )
39
- - [ Access community plugins from GitHub] ( #access-community-plugins-from-github )
40
- - [ Configure your triggers] ( #configure-your-triggers )
41
- - [ Install Python dependencies] ( #install-python-dependencies )
42
29
- [ Distributed cluster considerations] ( #distributed-cluster-considerations )
43
- - [ Match plugin types to the correct node] ( #match-plugin-types-to-the-correct-node )
44
- - [ Route third-party clients to querier nodes] ( #route-third-party-clients-to-querier-nodes )
45
30
46
31
## Set up the Processing Engine
47
32
@@ -239,7 +224,7 @@ def process_scheduled_call(influxdb3_local, call_time, args=None):
239
224
240
225
#### Create an HTTP request plugin
241
226
242
- HTTP request plugins respond to API calls using [ ` request: ` ] ( #trigger-on-http-requests ) trigger specifications{{% show-in "enterprise" %}} (CLI) or ` {"request_path": {"path": "..."}} ` (API){{% /show-in %}}. Use them for:
227
+ HTTP request plugins respond to API calls using [ ` request: ` ] ( #trigger-on-http-requests ) trigger specifications{{% show-in "enterprise" %}} (CLI) or ` {"request_path": {"path": "..."}} ` (HTTP API){{% /show-in %}}. Use them for:
243
228
244
229
- Creating custom API endpoints
245
230
- Webhooks for external integrations
@@ -278,7 +263,7 @@ After writing your plugin:
278
263
| ------------| ----------------------| -----------------|
279
264
| Data write | ` table:<TABLE_NAME> ` or ` all_tables ` | When data is written to tables |
280
265
| Scheduled | ` every:<DURATION> ` or ` cron:<EXPRESSION> ` | At specified time intervals |
281
- | HTTP request | ` request:<REQUEST_PATH> ` {{% show-in "enterprise" %}} (CLI) or ` {"request_path": {"path": "<REQUEST_PATH>"}} ` {{% /show-in %}} | When HTTP requests are received |
266
+ | HTTP request | ` request:<REQUEST_PATH> ` {{% show-in "enterprise" %}} (CLI) or ` {"request_path": {"path": "<REQUEST_PATH>"}} ` (HTTP API) {{% /show-in %}} | When HTTP requests are received |
282
267
283
268
### Use the create trigger command
284
269
@@ -615,7 +600,7 @@ Each plugin must run on a node that supports its trigger type:
615
600
| --------------------| --------------------------| -----------------------------|
616
601
| Data write | ` table: ` or ` all_tables ` | Ingester nodes |
617
602
| Scheduled | ` every: ` or ` cron: ` | Any node with scheduler |
618
- | HTTP request | ` request: ` {{% show-in "enterprise" %}} (CLI) or ` {"request_path": {"path": "..."}} ` {{% /show-in %}} | Nodes that serve API traffic|
603
+ | HTTP request | ` request: ` {{% show-in "enterprise" %}} (CLI) or ` {"request_path": {"path": "..."}} ` (HTTP API) {{% /show-in %}} | Nodes that serve API traffic|
619
604
620
605
{{% show-in "enterprise" %}}
621
606
> [ !Note]
0 commit comments