Skip to content

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

FieldTypeRequiredDescription
url Requesturl (string)The URL for this request.
Examples: https://example.com/path
trigger TriggerTriggerWhen and how to run this input. If omitted, runs exactly once.
retry ReliabilityRetryHow to retry operation if it fails.
batch ProcessingBatchMark each group of input events in a distinct way.
json Behaviorboolean (bool)Use for when data is text or already JSON.
payload-mode BehaviorPayload ModeSelect how the response body should be interpreted (auto, json, raw, binary).
Allowed values: auto, json, raw, binary
ignore-line-breaks Behaviorboolean (bool)Do not treat separate lines as distinct events.
events-field Processingfield (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 Processingboolean (bool)collect all the output together as a single document (will affect batching on the output).
headers Requestmap (string)Headers to send with the query.
query Requestmap (string)Query parameters to send with the query.
auth AuthenticationAuthHTTP authentication / signing strategy.
pagination PaginationPaginationOptional pagination handler configuration.
body Requestmultiline-text (string)The payload to send.
form-urlencoded-body Requestmap (string)Payload as key-value pairs posted as form-urlencoded.
method RequestMethodHTTP method to use for the query - default is GET.
Allowed values: get, post, put, patch, delete, options, head
timeout Reliabilitytime-interval (string)Timeout for the request (e.g. 500ms, 2s, etc. - the default is 30 seconds).
Examples: 500ms, 2h
response ResponseResponseFields to include in returned event.
insecure Securityboolean (bool)Ignore TLS certificate validation errors (This is unsafe to use).

Trigger

Show fields
FieldTypeRequiredDescription
triggerTriggerWhen and how to run this input. If omitted, runs exactly once.

Reliability

Show fields
FieldTypeRequiredDescription
retryRetryHow to retry operation if it fails.
timeouttime-interval (string)Timeout for the request (e.g. 500ms, 2s, etc. - the default is 30 seconds).
Examples: 500ms, 2h

Processing

Show fields
FieldTypeRequiredDescription
batchBatchMark each group of input events in a distinct way.
events-fieldfield (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-modeboolean (bool)collect all the output together as a single document (will affect batching on the output).

Request

Show fields
FieldTypeRequiredDescription
urlurl (string)The URL for this request.
Examples: https://example.com/path
headersmap (string)Headers to send with the query.
querymap (string)Query parameters to send with the query.
bodymultiline-text (string)The payload to send.
form-urlencoded-bodymap (string)Payload as key-value pairs posted as form-urlencoded.
methodMethodHTTP method to use for the query - default is GET.
Allowed values: get, post, put, patch, delete, options, head

Behavior

Show fields
FieldTypeRequiredDescription
jsonboolean (bool)Use for when data is text or already JSON.
payload-modePayload ModeSelect how the response body should be interpreted (auto, json, raw, binary).
Allowed values: auto, json, raw, binary
ignore-line-breaksboolean (bool)Do not treat separate lines as distinct events.

Authentication

Show fields
FieldTypeRequiredDescription
authAuthHTTP authentication / signing strategy.

Pagination

Show fields
FieldTypeRequiredDescription
paginationPaginationOptional pagination handler configuration.

Response

Show fields
FieldTypeRequiredDescription
responseResponseFields to include in returned event.

Security

Show fields
FieldTypeRequiredDescription
insecureboolean (bool)Ignore TLS certificate validation errors (This is unsafe to use).

Schema

Trigger - Cron - Window - Start Options

OptionNameTypeDescription
start-timeStart Timeobject
trackedTrackedstringExamples: /path/to/file, c:\users\joe\data\file.txt

Trigger - Interval - Window - Start Options

OptionNameTypeDescription
start-timeStart Timeobject
trackedTrackedstringExamples: /path/to/file, c:\users\joe\data\file.txt

Trigger Options

OptionNameTypeDescription
messageMessageobject
cronCronobject
intervalIntervalobject

Auth Options

OptionNameTypeDescription
basicBasicobject
header-tokenHeader Tokenobject
facebook-app-secretFacebook App Secretobject
aws-sig-v4Aws Sig V4object

Pagination Options

OptionNameTypeDescription
cursorCursorobject
link-headerLink Headerobject

Trigger - Message Fields

FieldTypeRequiredDescription
limitnumber (integer)The number of times to run the input.
Examples: 42, 1.2e-10
filter-kindFilter KindSpecifies 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-sourceFilter Source[]Specifies what process generated the message. Was it a “server”, “worker” or “job”?
Allowed values: job, worker, server
filter-workerstringSpecifies what worker to select.
filter-jobstringSpecifies the name of the job that the message came from.
filter-typeFilter 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-tagstringSpecifies 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

FieldTypeRequiredDescription
start-timetime-format (string)Allows the windowing to start at a specified time.
Hint: %Y-%m-%d %H:%M:%S%.3f %z
highwatermark-filepath (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

FieldTypeRequiredDescription
sizeduration (string)Window size.
offsetduration (string)Window offset.
startStartSpecify file where timestamp would be stored in order to resume, for when Job has been restarted.

Trigger - Cron Fields

FieldTypeRequiredDescription
croncron-expression (string)The Cron pattern.
immediateboolean (bool)Run as soon as invoked, instead of waiting for the specified cron interval.
random-offsetduration (string)Sets a random offset to the schedule, then sticks to it.
windowWindowOptional window definition when the schedule should only read a bounded range.

Trigger - Interval - Window - Start - Start Time Fields

FieldTypeRequiredDescription
start-timetime-format (string)Allows the windowing to start at a specified time.
Hint: %Y-%m-%d %H:%M:%S%.3f %z
highwatermark-filepath (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

FieldTypeRequiredDescription
sizeduration (string)Window size.
offsetduration (string)Window offset.
startStartSpecify file where timestamp would be stored in order to resume, for when Job has been restarted.

Trigger - Interval Fields

FieldTypeRequiredDescription
durationduration (string)Duration to wait between events.
random-offsetduration (string)Sets a random offset to the schedule, then sticks to it.
windowWindowOptional window definition when the interval should only cover a bounded range.

Retry Fields

FieldTypeRequiredDescription
timeouttime-interval (string)timeout (e.g. 500ms, 2s etc. - default is 30).
Examples: 500ms, 2h
retriesnumber (integer)number of retries.
Examples: 42, 1.2e-10

Batch Fields

FieldTypeRequiredDescription
uuid-fieldfield (string)Field where generated uuid, the unique marker for the group, will be stored.
Examples: data_field
invocation-time-fieldfield (string)Field where invocation time will be stored.
Examples: data_field
completion-time-fieldfield (string)Field where completion (end of execution) time will be stored.
Examples: data_field
begin-marker-fieldfield (string)Field used to mark first event in the group.
Examples: data_field
end-marker-fieldfield (string)Field used to mark last event in the group.
Examples: data_field
line-count-fieldfield (string)Field used to store the line count of the batch.
Examples: data_field
line-num-fieldfield (string)Field used to store the line number of the batch.
Examples: data_field

Auth - Basic Fields

FieldTypeRequiredDescription
usernamestringName of User.
passwordstringPassword.

Auth - Header Token Fields

FieldTypeRequiredDescription
strategystringAuthentication strategy identifier.
tokenstringToken value (literal or context/secret/credential reference).
auth-headerstringHeader used to carry the token.
prefixstringPrefix prepended to the token (use an empty string to send the token as-is).

Auth - Facebook App Secret Fields

FieldTypeRequiredDescription
strategystringAuthentication strategy identifier.
access-tokenstringAccess token (usually a user or page token). Accepts literal values or context/secret references ({{ ctx.facebook.token }}).
app-secretstringFacebook App Secret used to compute the HMAC proof (literal or context/secret reference).
proof-paramstringQuery parameter name used for the proof.
auth-headerstringHeader used to carry the access token.

Auth - Aws Sig V4 Fields

FieldTypeRequiredDescription
strategystringAuthentication strategy identifier.
access-key-idstringAWS access key id (literal or context/secret/credential reference).
secret-access-keystringAWS secret access key (literal or context/secret/credential reference).
session-tokenstringOptional AWS session token for temporary credentials (literal or context reference).
regionstringAWS region used to compute the signature (e.g. us-east-1).
servicestringAWS service name (defaults to execute-api when omitted).

Pagination - Cursor Fields

FieldTypeRequiredDescription
namespacestringWorker KV namespace in tenant:namespace form used to persist cursors.
cursor-keystringKey used to store the latest cursor for this poller.
cursor-query-paramstringQuery parameter appended for cursor pagination.
cursor-pointerjson-pointer (string)JSON pointer to extract the cursor value.
next-pointerjson-pointer (string)JSON pointer to extract the next page URL.
max-pages-per-runnumberMaximum number of pages fetched per run.
FieldTypeRequiredDescription
headerstringHeader to parse for pagination links.
relstringLink relation to follow (typically next).
max-pages-per-runnumberMaximum number of pages fetched per run.

Response Fields

FieldTypeRequiredDescription
jsonboolean (bool)Return response in JSON format as single line-delimited event.
status-fieldfield (string)Field to store HTTP status code.
Examples: data_field
headers-fieldfield (string)Field to store response headers.
Examples: data_field
response-fieldfield (string)Field to store the body of the response.
Examples: data_field

Headers Table

HeaderValue
Header-Namevalue

Value format: templated-text.

Query Table

ParameterValue
paramvalue

Value format: templated-text.

Form Urlencoded Body Table

FieldValue
fieldvalue

Value format: templated-text.

Trigger - Message - Filter Kind Options

ValueDescription
systemSystem
userUser
runtime-artifact-fetchRuntime Artifact Fetch
runtime-artifact-fetch-errorRuntime Artifact Fetch Error
runtime-artifact-clearRuntime Artifact Clear
runtime-artifact-clear-ackRuntime Artifact Clear Ack
runtime-artifact-fetch-replyRuntime Artifact Fetch Reply
runtime-artifact-updateRuntime Artifact Update
runtime-artifact-update-ackRuntime Artifact Update Ack

Trigger - Message - Filter Source Options

ValueDescription
jobJob
workerWorker
serverServer

Trigger - Message - Filter Type Options

ValueDescription
worker-licensedWorker Licensed
worker-unlicensedWorker Unlicensed
variableVariable
variable-deletedVariable Deleted
begin-shutting-down-jobBegin Shutting Down Job
begin-shutting-down-serverBegin Shutting Down Server
begin-shutting-down-workerBegin Shutting Down Worker
broadcast-job-thread-stateBroadcast Job Thread State
broadcast-server-thread-stateBroadcast Server Thread State
broadcast-worker-thread-stateBroadcast Worker Thread State
check-job-report-timeCheck Job Report Time
check-worker-report-timeCheck Worker Report Time
de-register-job-thread-dependencyDe Register Job Thread Dependency
de-register-server-thread-dependencyDe Register Server Thread Dependency
de-register-worker-thread-dependencyDe Register Worker Thread Dependency
deployed-job-activeDeployed Job Active
deployed-job-removedDeployed Job Removed
deployed-job-should-be-runningDeployed Job Should Be Running
deployment-phaseDeployment Phase
heart-beatHeart Beat
initialise-internal-stateInitialise Internal State
initialise-job-statesInitialise Job States
job-batch-endJob Batch End
job-backlog-updateJob Backlog Update
job-checkpoint-updateJob Checkpoint Update
job-deploy-readyJob Deploy Ready
job-deployedJob Deployed
job-document-endJob Document End
job-document-startJob Document Start
job-errorsJob Errors
job-execution-anomalyJob Execution Anomaly
job-execution-statusJob Execution Status
job-emit-customJob Emit Custom
job-finishedJob Finished
job-idleJob Idle
job-initiatedJob Initiated
job-is-processingJob Is Processing
job-logsJob Logs
job-metricsJob Metrics
job-notificationsJob Notifications
job-removingJob Removing
job-removedJob Removed
job-remove-failedJob Remove Failed
job-remove-readyJob Remove Ready
job-replacedJob Replaced
job-requiredJob Required
job-run-endedJob Run Ended
job-runtime-errorJob Runtime Error
job-runtime-settingsJob Runtime Settings
job-run-startedJob Run Started
job-running-dockerJob Running Docker
job-running-scriptJob Running Script
job-running-subprocessJob Running Subprocess
job-running-system-dJob Running System D
job-settingsJob Settings
job-step-statisticsJob Step Statistics
job-startedJob Started
job-stagedJob Staged
job-state-transitionJob State Transition
job-shutting-downJob Shutting Down
job-stoppingJob Stopping
job-stoppedJob Stopped
job-timed-outJob Timed Out
job-suspicious-silenceJob Suspicious Silence
job-thread-stateJob Thread State
job-traceJob Trace
job-trace-requires-samplesJob Trace Requires Samples
job-updatedJob Updated
job-worker-comms-errorJob Worker Comms Error
job-unstagedJob Unstaged
license-state-changedLicense State Changed
license-validation-failedLicense Validation Failed
license-validation-okLicense Validation Ok
license-volume-violationLicense Volume Violation
new-licenseNew License
override-job-coordinated-shutdownOverride Job Coordinated Shutdown
override-server-coordinated-shutdownOverride Server Coordinated Shutdown
override-worker-coordinated-shutdownOverride Worker Coordinated Shutdown
register-job-thread-dependencyRegister Job Thread Dependency
register-server-thread-dependencyRegister Server Thread Dependency
register-worker-thread-dependencyRegister Worker Thread Dependency
run-job-failureRun Job Failure
server-logsServer Logs
server-metrics-batchServer Metrics Batch
server-startedServer Started
server-startingServer Starting
server-stoppingServer Stopping
server-thread-stateServer Thread State
server-worker-comms-errorServer Worker Comms Error
shutdown-jobsShutdown Jobs
shutdown-workerShutdown Worker
system-shutdownSystem Shutdown
update-upstream-sync-for-jobUpdate Upstream Sync For Job
update-upstream-sync-for-workerUpdate Upstream Sync For Worker
update-variableUpdate Variable
user-alertUser Alert
user-generatedUser Generated
user-notificationUser Notification
worker-command-for-jobWorker Command For Job
worker-auth-lease-ackWorker Auth Lease Ack
worker-connectedWorker Connected
worker-createdWorker Created
worker-debug-heart-beatWorker Debug Heart Beat
worker-errorWorker Error
worker-first-seenWorker First Seen
worker-heart-beatWorker Heart Beat
worker-logsWorker Logs
worker-metrics-batchWorker Metrics Batch
worker-offlineWorker Offline
worker-requests-auth-leaseWorker Requests Auth Lease
worker-server-comms-errorWorker Server Comms Error
worker-settingsWorker Settings
worker-shutdownWorker Shutdown
worker-shutting-downWorker Shutting Down
worker-startedWorker Started
worker-state-uuidWorker State Uuid
worker-stoppingWorker Stopping
worker-suspicious-silenceWorker Suspicious Silence
worker-system-informationWorker System Information
worker-thread-stateWorker Thread State
worker-updatedWorker Updated
worker-modifiedWorker Modified
worker-removedWorker Removed
context-changedContext Changed
rerender-deploymentRerender Deployment
job-killedJob Killed
message-servicedMessage Serviced
failed-to-service-messageFailed To Service Message
worker-wants-initial-settingsWorker Wants Initial Settings
worker-wants-initial-settings-replyWorker Wants Initial Settings Reply
worker-wants-deployed-jobsWorker Wants Deployed Jobs
worker-wants-deployed-jobs-replyWorker Wants Deployed Jobs Reply
worker-wants-job-configurationWorker Wants Job Configuration
worker-wants-job-configuration-replyWorker Wants Job Configuration Reply
job-wants-dslir-keyJob Wants Dslir Key
job-wants-dslir-key-replyJob Wants Dslir Key Reply
worker-wants-dslir-keyWorker Wants Dslir Key
worker-wants-dslir-key-replyWorker Wants Dslir Key Reply
job-wants-variablesJob Wants Variables
job-wants-variables-replyJob Wants Variables Reply
job-wants-credentialsJob Wants Credentials
job-wants-credentials-replyJob Wants Credentials Reply
job-wants-credentials-errorJob Wants Credentials Error
job-wants-secret-variables-replyJob Wants Secret Variables Reply
job-credentials-invalidatedJob Credentials Invalidated
aggregator-healthAggregator Health
worker-verification-tokenWorker Verification Token
worker-requests-verification-tokenWorker Requests Verification Token
runtime-artifact-updateRuntime Artifact Update
runtime-artifact-update-ackRuntime Artifact Update Ack
runtime-artifact-clearRuntime Artifact Clear
runtime-artifact-clear-ackRuntime Artifact Clear Ack
runtime-artifact-fetchRuntime Artifact Fetch
runtime-artifact-fetch-replyRuntime Artifact Fetch Reply
runtime-artifact-fetch-errorRuntime Artifact Fetch Error

Payload Mode Options

ValueDescription
autoAuto
jsonJson
rawRaw
binaryBinary

Method Options

ValueDescription
getGet
postPost
putPut
patchPatch
deleteDelete
optionsOptions
headHead