HTTP Poll
HTTP Poll (http-poll)
Run HTTP queries.
Http binary json raw
Minimal example
input: http-poll: url: ""JSON
{ "input": { "http-poll": { "url": "" } }}Contents
Fields
| Field | Type | Required | Description |
|---|---|---|---|
url Request | url (string) | ✅ | The URL for this request. Examples: https://example.com/path |
trigger Trigger | Trigger | When and how to run this input. If omitted, runs exactly once. | |
retry Reliability | Retry | How to retry operation if it fails. | |
batch Processing | Batch | Mark each group of input events in a distinct way. | |
json Behavior | boolean (bool) | Use for when data is text or already JSON. | |
payload-mode Behavior | Payload Mode | Select how the response body should be interpreted (auto, json, raw, binary).Allowed values: auto, json, raw, binary | |
ignore-line-breaks Behavior | boolean (bool) | Do not treat separate lines as distinct events. | |
events-field Processing | field (string) | extract events from this field of the response, assumed to be an array. Body is assumed to be JSON and we ignore line breaks. Examples: data_field | |
document-mode Processing | boolean (bool) | collect all the output together as a single document (will affect batching on the output). | |
headers Request | map (string) | Headers to send with the query. | |
query Request | map (string) | Query parameters to send with the query. | |
auth Authentication | Auth | HTTP authentication / signing strategy. | |
pagination Pagination | Pagination | Optional pagination handler configuration. | |
body Request | multiline-text (string) | The payload to send. | |
form-urlencoded-body Request | map (string) | Payload as key-value pairs posted as form-urlencoded. | |
method Request | Method | HTTP method to use for the query - default is GET. Allowed values: get, post, put, patch, delete, options, head | |
timeout Reliability | time-interval (string) | Timeout for the request (e.g. 500ms, 2s, etc. - the default is 30 seconds). Examples: 500ms, 2h | |
response Response | Response | Fields to include in returned event. | |
insecure Security | boolean (bool) | Ignore TLS certificate validation errors (This is unsafe to use). |
Trigger
Show fields
| Field | Type | Required | Description |
|---|---|---|---|
trigger | Trigger | When and how to run this input. If omitted, runs exactly once. |
Reliability
Show fields
| Field | Type | Required | Description |
|---|---|---|---|
retry | Retry | How to retry operation if it fails. | |
timeout | time-interval (string) | Timeout for the request (e.g. 500ms, 2s, etc. - the default is 30 seconds). Examples: 500ms, 2h |
Processing
Show fields
| Field | Type | Required | Description |
|---|---|---|---|
batch | Batch | Mark each group of input events in a distinct way. | |
events-field | field (string) | extract events from this field of the response, assumed to be an array. Body is assumed to be JSON and we ignore line breaks. Examples: data_field | |
document-mode | boolean (bool) | collect all the output together as a single document (will affect batching on the output). |
Request
Show fields
| Field | Type | Required | Description |
|---|---|---|---|
url | url (string) | ✅ | The URL for this request. Examples: https://example.com/path |
headers | map (string) | Headers to send with the query. | |
query | map (string) | Query parameters to send with the query. | |
body | multiline-text (string) | The payload to send. | |
form-urlencoded-body | map (string) | Payload as key-value pairs posted as form-urlencoded. | |
method | Method | HTTP method to use for the query - default is GET. Allowed values: get, post, put, patch, delete, options, head |
Behavior
Show fields
| Field | Type | Required | Description |
|---|---|---|---|
json | boolean (bool) | Use for when data is text or already JSON. | |
payload-mode | Payload Mode | Select how the response body should be interpreted (auto, json, raw, binary).Allowed values: auto, json, raw, binary | |
ignore-line-breaks | boolean (bool) | Do not treat separate lines as distinct events. |
Authentication
Show fields
| Field | Type | Required | Description |
|---|---|---|---|
auth | Auth | HTTP authentication / signing strategy. |
Pagination
Show fields
| Field | Type | Required | Description |
|---|---|---|---|
pagination | Pagination | Optional pagination handler configuration. |
Response
Show fields
| Field | Type | Required | Description |
|---|---|---|---|
response | Response | Fields to include in returned event. |
Security
Show fields
| Field | Type | Required | Description |
|---|---|---|---|
insecure | boolean (bool) | Ignore TLS certificate validation errors (This is unsafe to use). |
Schema
- Trigger - Cron - Window - Start Options
- Trigger - Interval - Window - Start Options
- Trigger Options
- Auth Options
- Pagination Options
- Trigger - Message Fields
- Trigger - Cron - Window - Start - Start Time Fields
- Trigger - Cron - Window Fields
- Trigger - Cron Fields
- Trigger - Interval - Window - Start - Start Time Fields
- Trigger - Interval - Window Fields
- Trigger - Interval Fields
- Retry Fields
- Batch Fields
- Auth - Basic Fields
- Auth - Header Token Fields
- Auth - Facebook App Secret Fields
- Auth - Aws Sig V4 Fields
- Pagination - Cursor Fields
- Pagination - Link Header Fields
- Response Fields
- Headers Table
- Query Table
- Form Urlencoded Body Table
- Trigger - Message - Filter Kind Options
- Trigger - Message - Filter Source Options
- Trigger - Message - Filter Type Options
- Payload Mode Options
- Method Options
Trigger - Cron - Window - Start Options
| Option | Name | Type | Description |
|---|---|---|---|
start-time | Start Time | object | |
tracked | Tracked | string | Examples: /path/to/file, c:\users\joe\data\file.txt |
Trigger - Interval - Window - Start Options
| Option | Name | Type | Description |
|---|---|---|---|
start-time | Start Time | object | |
tracked | Tracked | string | Examples: /path/to/file, c:\users\joe\data\file.txt |
Trigger Options
| Option | Name | Type | Description |
|---|---|---|---|
message | Message | object | |
cron | Cron | object | |
interval | Interval | object |
Auth Options
| Option | Name | Type | Description |
|---|---|---|---|
basic | Basic | object | |
header-token | Header Token | object | |
facebook-app-secret | Facebook App Secret | object | |
aws-sig-v4 | Aws Sig V4 | object |
Pagination Options
| Option | Name | Type | Description |
|---|---|---|---|
cursor | Cursor | object | |
link-header | Link Header | object |
Trigger - Message Fields
| Field | Type | Required | Description |
|---|---|---|---|
limit | number (integer) | The number of times to run the input. Examples: 42, 1.2e-10 | |
filter-kind | Filter Kind | Specifies whether the message originated from the “system” or by the “user”. Allowed values: system, user, runtime-artifact-fetch, runtime-artifact-fetch-error, runtime-artifact-clear, runtime-artifact-clear-ack, runtime-artifact-fetch-reply, runtime-artifact-update, … | |
filter-source | Filter Source[] | Specifies what process generated the message. Was it a “server”, “worker” or “job”? Allowed values: job, worker, server | |
filter-worker | string | Specifies what worker to select. | |
filter-job | string | Specifies the name of the job that the message came from. | |
filter-type | Filter Type[] | Specifies that particular types of message ought to match. Allowed values: worker-licensed, worker-unlicensed, variable, variable-deleted, begin-shutting-down-job, begin-shutting-down-server, begin-shutting-down-worker, broadcast-job-thread-state, … | |
filter-tag | string | Specifies that messages matched ought to carry a tag with a particular value. This only matches against user-generated messages. |
Trigger - Cron - Window - Start - Start Time Fields
| Field | Type | Required | Description |
|---|---|---|---|
start-time | time-format (string) | ✅ | Allows the windowing to start at a specified time. Hint: %Y-%m-%d %H:%M:%S%.3f %z |
highwatermark-file | path (string) | ✅ | Specify file where timestamp would be stored in order to resume, for when Job has been restarted. Examples: /path/to/file, c:\users\joe\data\file.txt |
Trigger - Cron - Window Fields
| Field | Type | Required | Description |
|---|---|---|---|
size | duration (string) | ✅ | Window size. |
offset | duration (string) | Window offset. | |
start | Start | Specify file where timestamp would be stored in order to resume, for when Job has been restarted. |
Trigger - Cron Fields
| Field | Type | Required | Description |
|---|---|---|---|
cron | cron-expression (string) | ✅ | The Cron pattern. |
immediate | boolean (bool) | Run as soon as invoked, instead of waiting for the specified cron interval. | |
random-offset | duration (string) | Sets a random offset to the schedule, then sticks to it. | |
window | Window | Optional window definition when the schedule should only read a bounded range. |
Trigger - Interval - Window - Start - Start Time Fields
| Field | Type | Required | Description |
|---|---|---|---|
start-time | time-format (string) | ✅ | Allows the windowing to start at a specified time. Hint: %Y-%m-%d %H:%M:%S%.3f %z |
highwatermark-file | path (string) | ✅ | Specify file where timestamp would be stored in order to resume, for when Job has been restarted. Examples: /path/to/file, c:\users\joe\data\file.txt |
Trigger - Interval - Window Fields
| Field | Type | Required | Description |
|---|---|---|---|
size | duration (string) | ✅ | Window size. |
offset | duration (string) | Window offset. | |
start | Start | Specify file where timestamp would be stored in order to resume, for when Job has been restarted. |
Trigger - Interval Fields
| Field | Type | Required | Description |
|---|---|---|---|
duration | duration (string) | ✅ | Duration to wait between events. |
random-offset | duration (string) | Sets a random offset to the schedule, then sticks to it. | |
window | Window | Optional window definition when the interval should only cover a bounded range. |
Retry Fields
| Field | Type | Required | Description |
|---|---|---|---|
timeout | time-interval (string) | ✅ | timeout (e.g. 500ms, 2s etc. - default is 30). Examples: 500ms, 2h |
retries | number (integer) | number of retries. Examples: 42, 1.2e-10 |
Batch Fields
| Field | Type | Required | Description |
|---|---|---|---|
uuid-field | field (string) | Field where generated uuid, the unique marker for the group, will be stored. Examples: data_field | |
invocation-time-field | field (string) | Field where invocation time will be stored. Examples: data_field | |
completion-time-field | field (string) | Field where completion (end of execution) time will be stored. Examples: data_field | |
begin-marker-field | field (string) | Field used to mark first event in the group. Examples: data_field | |
end-marker-field | field (string) | Field used to mark last event in the group. Examples: data_field | |
line-count-field | field (string) | Field used to store the line count of the batch. Examples: data_field | |
line-num-field | field (string) | Field used to store the line number of the batch. Examples: data_field |
Auth - Basic Fields
| Field | Type | Required | Description |
|---|---|---|---|
username | string | ✅ | Name of User. |
password | string | ✅ | Password. |
Auth - Header Token Fields
| Field | Type | Required | Description |
|---|---|---|---|
strategy | string | Authentication strategy identifier. | |
token | string | ✅ | Token value (literal or context/secret/credential reference). |
auth-header | string | Header used to carry the token. | |
prefix | string | Prefix prepended to the token (use an empty string to send the token as-is). |
Auth - Facebook App Secret Fields
| Field | Type | Required | Description |
|---|---|---|---|
strategy | string | Authentication strategy identifier. | |
access-token | string | ✅ | Access token (usually a user or page token). Accepts literal values or context/secret references ({{ ctx.facebook.token }}). |
app-secret | string | ✅ | Facebook App Secret used to compute the HMAC proof (literal or context/secret reference). |
proof-param | string | Query parameter name used for the proof. | |
auth-header | string | Header used to carry the access token. |
Auth - Aws Sig V4 Fields
| Field | Type | Required | Description |
|---|---|---|---|
strategy | string | Authentication strategy identifier. | |
access-key-id | string | ✅ | AWS access key id (literal or context/secret/credential reference). |
secret-access-key | string | ✅ | AWS secret access key (literal or context/secret/credential reference). |
session-token | string | Optional AWS session token for temporary credentials (literal or context reference). | |
region | string | ✅ | AWS region used to compute the signature (e.g. us-east-1). |
service | string | AWS service name (defaults to execute-api when omitted). |
Pagination - Cursor Fields
| Field | Type | Required | Description |
|---|---|---|---|
namespace | string | ✅ | Worker KV namespace in tenant:namespace form used to persist cursors. |
cursor-key | string | ✅ | Key used to store the latest cursor for this poller. |
cursor-query-param | string | Query parameter appended for cursor pagination. | |
cursor-pointer | json-pointer (string) | JSON pointer to extract the cursor value. | |
next-pointer | json-pointer (string) | JSON pointer to extract the next page URL. | |
max-pages-per-run | number | Maximum number of pages fetched per run. |
Pagination - Link Header Fields
| Field | Type | Required | Description |
|---|---|---|---|
header | string | Header to parse for pagination links. | |
rel | string | Link relation to follow (typically next). | |
max-pages-per-run | number | Maximum number of pages fetched per run. |
Response Fields
| Field | Type | Required | Description |
|---|---|---|---|
json | boolean (bool) | Return response in JSON format as single line-delimited event. | |
status-field | field (string) | Field to store HTTP status code. Examples: data_field | |
headers-field | field (string) | Field to store response headers. Examples: data_field | |
response-field | field (string) | Field to store the body of the response. Examples: data_field |
Headers Table
| Header | Value |
|---|---|
Header-Name | value |
Value format: templated-text.
Query Table
| Parameter | Value |
|---|---|
param | value |
Value format: templated-text.
Form Urlencoded Body Table
| Field | Value |
|---|---|
field | value |
Value format: templated-text.
Trigger - Message - Filter Kind Options
| Value | Description |
|---|---|
system | System |
user | User |
runtime-artifact-fetch | Runtime Artifact Fetch |
runtime-artifact-fetch-error | Runtime Artifact Fetch Error |
runtime-artifact-clear | Runtime Artifact Clear |
runtime-artifact-clear-ack | Runtime Artifact Clear Ack |
runtime-artifact-fetch-reply | Runtime Artifact Fetch Reply |
runtime-artifact-update | Runtime Artifact Update |
runtime-artifact-update-ack | Runtime Artifact Update Ack |
Trigger - Message - Filter Source Options
| Value | Description |
|---|---|
job | Job |
worker | Worker |
server | Server |
Trigger - Message - Filter Type Options
| Value | Description |
|---|---|
worker-licensed | Worker Licensed |
worker-unlicensed | Worker Unlicensed |
variable | Variable |
variable-deleted | Variable Deleted |
begin-shutting-down-job | Begin Shutting Down Job |
begin-shutting-down-server | Begin Shutting Down Server |
begin-shutting-down-worker | Begin Shutting Down Worker |
broadcast-job-thread-state | Broadcast Job Thread State |
broadcast-server-thread-state | Broadcast Server Thread State |
broadcast-worker-thread-state | Broadcast Worker Thread State |
check-job-report-time | Check Job Report Time |
check-worker-report-time | Check Worker Report Time |
de-register-job-thread-dependency | De Register Job Thread Dependency |
de-register-server-thread-dependency | De Register Server Thread Dependency |
de-register-worker-thread-dependency | De Register Worker Thread Dependency |
deployed-job-active | Deployed Job Active |
deployed-job-removed | Deployed Job Removed |
deployed-job-should-be-running | Deployed Job Should Be Running |
deployment-phase | Deployment Phase |
heart-beat | Heart Beat |
initialise-internal-state | Initialise Internal State |
initialise-job-states | Initialise Job States |
job-batch-end | Job Batch End |
job-backlog-update | Job Backlog Update |
job-checkpoint-update | Job Checkpoint Update |
job-deploy-ready | Job Deploy Ready |
job-deployed | Job Deployed |
job-document-end | Job Document End |
job-document-start | Job Document Start |
job-errors | Job Errors |
job-execution-anomaly | Job Execution Anomaly |
job-execution-status | Job Execution Status |
job-emit-custom | Job Emit Custom |
job-finished | Job Finished |
job-idle | Job Idle |
job-initiated | Job Initiated |
job-is-processing | Job Is Processing |
job-logs | Job Logs |
job-metrics | Job Metrics |
job-notifications | Job Notifications |
job-removing | Job Removing |
job-removed | Job Removed |
job-remove-failed | Job Remove Failed |
job-remove-ready | Job Remove Ready |
job-replaced | Job Replaced |
job-required | Job Required |
job-run-ended | Job Run Ended |
job-runtime-error | Job Runtime Error |
job-runtime-settings | Job Runtime Settings |
job-run-started | Job Run Started |
job-running-docker | Job Running Docker |
job-running-script | Job Running Script |
job-running-subprocess | Job Running Subprocess |
job-running-system-d | Job Running System D |
job-settings | Job Settings |
job-step-statistics | Job Step Statistics |
job-started | Job Started |
job-staged | Job Staged |
job-state-transition | Job State Transition |
job-shutting-down | Job Shutting Down |
job-stopping | Job Stopping |
job-stopped | Job Stopped |
job-timed-out | Job Timed Out |
job-suspicious-silence | Job Suspicious Silence |
job-thread-state | Job Thread State |
job-trace | Job Trace |
job-trace-requires-samples | Job Trace Requires Samples |
job-updated | Job Updated |
job-worker-comms-error | Job Worker Comms Error |
job-unstaged | Job Unstaged |
license-state-changed | License State Changed |
license-validation-failed | License Validation Failed |
license-validation-ok | License Validation Ok |
license-volume-violation | License Volume Violation |
new-license | New License |
override-job-coordinated-shutdown | Override Job Coordinated Shutdown |
override-server-coordinated-shutdown | Override Server Coordinated Shutdown |
override-worker-coordinated-shutdown | Override Worker Coordinated Shutdown |
register-job-thread-dependency | Register Job Thread Dependency |
register-server-thread-dependency | Register Server Thread Dependency |
register-worker-thread-dependency | Register Worker Thread Dependency |
run-job-failure | Run Job Failure |
server-logs | Server Logs |
server-metrics-batch | Server Metrics Batch |
server-started | Server Started |
server-starting | Server Starting |
server-stopping | Server Stopping |
server-thread-state | Server Thread State |
server-worker-comms-error | Server Worker Comms Error |
shutdown-jobs | Shutdown Jobs |
shutdown-worker | Shutdown Worker |
system-shutdown | System Shutdown |
update-upstream-sync-for-job | Update Upstream Sync For Job |
update-upstream-sync-for-worker | Update Upstream Sync For Worker |
update-variable | Update Variable |
user-alert | User Alert |
user-generated | User Generated |
user-notification | User Notification |
worker-command-for-job | Worker Command For Job |
worker-auth-lease-ack | Worker Auth Lease Ack |
worker-connected | Worker Connected |
worker-created | Worker Created |
worker-debug-heart-beat | Worker Debug Heart Beat |
worker-error | Worker Error |
worker-first-seen | Worker First Seen |
worker-heart-beat | Worker Heart Beat |
worker-logs | Worker Logs |
worker-metrics-batch | Worker Metrics Batch |
worker-offline | Worker Offline |
worker-requests-auth-lease | Worker Requests Auth Lease |
worker-server-comms-error | Worker Server Comms Error |
worker-settings | Worker Settings |
worker-shutdown | Worker Shutdown |
worker-shutting-down | Worker Shutting Down |
worker-started | Worker Started |
worker-state-uuid | Worker State Uuid |
worker-stopping | Worker Stopping |
worker-suspicious-silence | Worker Suspicious Silence |
worker-system-information | Worker System Information |
worker-thread-state | Worker Thread State |
worker-updated | Worker Updated |
worker-modified | Worker Modified |
worker-removed | Worker Removed |
context-changed | Context Changed |
rerender-deployment | Rerender Deployment |
job-killed | Job Killed |
message-serviced | Message Serviced |
failed-to-service-message | Failed To Service Message |
worker-wants-initial-settings | Worker Wants Initial Settings |
worker-wants-initial-settings-reply | Worker Wants Initial Settings Reply |
worker-wants-deployed-jobs | Worker Wants Deployed Jobs |
worker-wants-deployed-jobs-reply | Worker Wants Deployed Jobs Reply |
worker-wants-job-configuration | Worker Wants Job Configuration |
worker-wants-job-configuration-reply | Worker Wants Job Configuration Reply |
job-wants-dslir-key | Job Wants Dslir Key |
job-wants-dslir-key-reply | Job Wants Dslir Key Reply |
worker-wants-dslir-key | Worker Wants Dslir Key |
worker-wants-dslir-key-reply | Worker Wants Dslir Key Reply |
job-wants-variables | Job Wants Variables |
job-wants-variables-reply | Job Wants Variables Reply |
job-wants-credentials | Job Wants Credentials |
job-wants-credentials-reply | Job Wants Credentials Reply |
job-wants-credentials-error | Job Wants Credentials Error |
job-wants-secret-variables-reply | Job Wants Secret Variables Reply |
job-credentials-invalidated | Job Credentials Invalidated |
aggregator-health | Aggregator Health |
worker-verification-token | Worker Verification Token |
worker-requests-verification-token | Worker Requests Verification Token |
runtime-artifact-update | Runtime Artifact Update |
runtime-artifact-update-ack | Runtime Artifact Update Ack |
runtime-artifact-clear | Runtime Artifact Clear |
runtime-artifact-clear-ack | Runtime Artifact Clear Ack |
runtime-artifact-fetch | Runtime Artifact Fetch |
runtime-artifact-fetch-reply | Runtime Artifact Fetch Reply |
runtime-artifact-fetch-error | Runtime Artifact Fetch Error |
Payload Mode Options
| Value | Description |
|---|---|
auto | Auto |
json | Json |
raw | Raw |
binary | Binary |
Method Options
| Value | Description |
|---|---|
get | Get |
post | Post |
put | Put |
patch | Patch |
delete | Delete |
options | Options |
head | Head |