AuditLogShipper

AuditLogShipper

Forward workflow audit logs to one or more desired destinations.

yaml
type: io.kestra.plugin.ee.core.log.AuditLogShipper

Examples

yaml
id: auditLogShipper
namespace: system

tasks:
  - id: shipLogs
    type: io.kestra.plugin.ee.core.log.AuditLogShipper
    resources:
      - FLOW
      - EXECUTION
    lookbackPeriod: P1D
    offsetKey: auditLogShipperOffset
    delete: false
    logExporters:
      - id: file
        type: io.kestra.plugin.ee.core.log.FileLogExporter

      - id: awsCloudWatch
        type: io.kestra.plugin.ee.aws.cloudwatch.LogExporter
        accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
        secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
        region: us-east-1
        logGroupName: kestra
        logStreamName: production

      - id: S3LogExporter
        type: io.kestra.plugin.ee.aws.s3.LogExporter
        accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
        secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
        region: "{{ vars.region }}"
        format: JSON
        bucket: logbucket
        logFilePrefix: kestra-log-file
        maxLinesPerFile: 1000000

      - id: googleOperationalSuite
        type: io.kestra.plugin.ee.gcp.operationalsuite.LogExporter
        projectId: my-gcp-project

      - id: gcs
        type: io.kestra.plugin.ee.gcp.gcs.LogExporter
        projectId: myProjectId
        format: JSON
        maxLinesPerFile: 10000
        bucket: my-bucket
        logFilePrefix: kestra-log-file
        chunk: 1000

      - id: azureMonitor
        type: io.kestra.plugin.ee.azure.monitor.LogExporter
        endpoint: https://endpoint-host.ingest.monitor.azure.com
        tenantId: "{{ secret('AZURE_TENANT_ID') }}"
        clientId: "{{ secret('AZURE_CLIENT_ID') }}"
        clientSecret: "{{ secret('AZURE_CLIENT_SECRET') }}"
        ruleId: dcr-69f0b123041d4d6e9f2bf72aad0b62cf
        streamName: kestraLogs

      - id: azureBlobStorage
        type: io.kestra.plugin.ee.azure.storage.LogExporter
        endpoint: https://myblob.blob.core.windows.net/
        tenantId: "{{ secret('AZURE_TENANT_ID') }}"
        clientId: "{{ secret('AZURE_CLIENT_ID') }}"
        clientSecret: "{{ secret('AZURE_CLIENT_SECRET') }}"
        containerName: logs
        format: JSON
        logFilePrefix: kestra-log-file
        maxLinesPerFile: 1000000
        chunk: 1000

      - id: datadog
        type: io.kestra.plugin.ee.datadog.LogExporter
        basePath: https://http-intake.logs.datadoghq.eu
        apiKey: "{{ secret('DATADOG_API_KEY') }}"

      - id: elasticsearch
        type: io.kestra.plugin.ee.elasticsearch.LogExporter
        indexName: kestra-logs
        connection:
          basicAuth:
            password: "{{ secret('ES_PASSWORD') }}"
            username: kestra_user
          hosts:
            - https://elastic.example.com:9200

      - id: opensearch
        type: io.kestra.plugin.ee.opensearch.LogExporter
        indexName: kestra-logs
        connection:
          basicAuth:
            password: "{{ secret('ES_PASSWORD') }}"
            username: kestra_user
          hosts:
            - https://elastic.example.com:9200

      - id: newRelic
        type: io.kestra.plugin.ee.newrelic.LogExporter
        basePath: https://log-api.newrelic.com
        apiKey: "{{ secret('NEWRELIC_API_KEY') }}"

      - id: openTelemetry
        type: io.kestra.plugin.ee.opentelemetry.LogExporter
        otlpEndpoint: http://otel-collector:4318/v1/logs
        authorizationHeaderName: Authorization
        authorizationHeaderValue: "Bearer {{ secret('OTEL_TOKEN') }}"

triggers:
  - id: dailySchedule
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "0 0 * * *"
    disabled: true

Properties

logExporters *

Min items1

Definitions

Ship logs to a file inside Kestra's internal storage.

Example

yaml
id: logShipper
namespace: company.team

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

tasks:
  - id: logSync
    type: io.kestra.plugin.ee.core.log.LogShipper
    logExporters:
      - id: file
        type: io.kestra.plugin.ee.core.log.FileLogExporter
        format: JSON
        maxLinesPerFile: 100

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

type*object

formatstring

DefaultION

Possible Values

IONJSON

logFilePrefixstring

Defaultkestra-log-file

maxLinesPerFileintegerstring

Export logs to Azure Monitor

Example

yaml
id: log_shipper
namespace: company.team

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

tasks:
  - id: log_export
    type: io.kestra.plugin.ee.core.log.LogShipper
    logLevelFilter: INFO
    batchSize: 1000
    lookbackPeriod: P1D
    logExporters:
      - id: AzureLogExporter
        type: io.kestra.plugin.ee.azure.monitor.LogExporter
        endpoint: https://endpoint-host.ingest.monitor.azure.com
        tenantId: tenant_id
        clientId: client_id
        clientSecret: client_secret
        ruleId: dcr-69f0b123041d4d6e9f2bf72aad0b62cf
        streamName: Custom-JSONLogs

endpoint*string

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

ruleId*string

streamName*string

type*object

chunkintegerstring

Default1000

clientIdstring

clientSecretstring

pemCertificatestring

tenantIdstring

Export logs to Azure Blob Storage

Example

yaml
id: log_shipper
namespace: company.team

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

tasks:
  - id: log_export
    type: io.kestra.plugin.ee.core.log.LogShipper
    logLevelFilter: INFO
    batchSize: 1000
    lookbackPeriod: P1D
    logExporters:
      - id: AzureLogExporter
        type: io.kestra.plugin.ee.azure.storage.LogExporter
        endpoint: https://myblob.blob.core.windows.net/
        tenantId: tenant_id
        clientId: client_id
        clientSecret: client_secret
        containerName: logs
        format: JSON
        logFilePrefix: kestra-log-file
        maxLinesPerFile: 1000000
        chunk: 1000

containerName*string

endpoint*string

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

type*object

chunkintegerstring

Default1000

clientIdstring

clientSecretstring

connectionStringstring

formatstring

DefaultJSON

Possible Values

IONJSON

logFilePrefixstring

Defaultkestra-log-file

maxLinesPerFileintegerstring

Default100000

pemCertificatestring

sasTokenstring

sharedKeyAccountAccessKeystring

sharedKeyAccountNamestring

tenantIdstring

Bulk export logs to Elasticsearch

Example

yaml
id: log_shipper
namespace: company.team

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

tasks:
  - id: logSync
    type: io.kestra.plugin.ee.core.log.LogShipper
    logLevelFilter: INFO
    batchSize: 1000
    lookbackPeriod: P1D
    logExporters:
      - id: ElasticsearchLogExporter
        type: io.kestra.plugin.ee.elasticsearch.LogExporter
        connection:
          hosts:
            - "http://localhost:9200/"
        indexName: "logs"

connection*

io.kestra.plugin.ee.elasticsearch.ElasticsearchConnection

hosts*array

SubTypestring

Min items1

basicAuth

io.kestra.plugin.ee.elasticsearch.ElasticsearchConnection-BasicAuth

passwordstring

usernamestring

headersarray

SubTypestring

pathPrefixstring

strictDeprecationModebooleanstring

targetServerVersionintegerstring

Default8

trustAllSslbooleanstring

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

indexName*string

type*object

chunkintegerstring

Default1000

Export logs to AWS CloudWatch

Example

yaml
id: log_shipper
namespace: system

tasks:
  - id: log_export
    type: io.kestra.plugin.ee.core.log.LogShipper
    logLevelFilter: INFO
    batchSize: 1000
    lookbackPeriod: P1D
    logExporters:
      - id: AWSLogExporter
        type: io.kestra.plugin.ee.aws.cloudwatch.LogExporter
        accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
        secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
        region: "{{ vars.region }}"
        logGroupName: group_name
        logStreamName: stream_name

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

logGroupName*string

logStreamName*string

region*string

type*object

accessKeyIdstring

chunkintegerstring

Default1000

endpointOverridestring

secretKeyIdstring

sessionTokenstring

stsEndpointOverridestring

stsRoleArnstring

stsRoleExternalIdstring

stsRoleSessionDurationstring

DefaultPT15M

stsRoleSessionNamestring

Export logs to S3

Example

yaml
id: log_shipper
namespace: system

tasks:
  - id: log_export
    type: io.kestra.plugin.ee.core.log.LogShipper
    logLevelFilter: INFO
    batchSize: 1000
    lookbackPeriod: P1D
    logExporters:
      - id: S3LogExporter
        type: io.kestra.plugin.ee.aws.s3.LogExporter
        accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
        secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
        region: "{{ vars.region }}"
        format: JSON
        bucket: logbucket
        logFilePrefix: kestra-log-file
        maxLinesPerFile: 1000000

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

bucket*string

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

region*string

type*object

accessKeyIdstring

chunkintegerstring

Default1000

endpointOverridestring

formatstring

DefaultJSON

Possible Values

IONJSON

logFilePrefixstring

Defaultkestra-log-file

maxLinesPerFileintegerstring

Default100000

secretKeyIdstring

sessionTokenstring

stsEndpointOverridestring

stsRoleArnstring

stsRoleExternalIdstring

stsRoleSessionDurationstring

DefaultPT15M

stsRoleSessionNamestring

Send logs to an OTLP collector

Example

yaml
id: log_shipper
namespace: company.team

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

tasks:
  - id: log_export
    type: io.kestra.plugin.ee.core.log.LogShipper
    logLevelFilter: INFO
    batchSize: 1000
    lookbackPeriod: P1D
    logExporters:
      - id: OTLPLogExporter
        type: io.kestra.plugin.ee.opentelemetry.LogExporter
        otlpEndpoint: http://localhost:4318/v1/logs
        authorizationHeaderName: Authorization
        authorizationHeaderValue: Bearer token

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

otlpEndpoint*string

type*object

authorizationHeaderNamestring

authorizationHeaderValuestring

chunkintegerstring

Default1000

Write logs to Google Cloud Storage

Example

yaml
id: log_shipper
namespace: company.team

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

tasks:
  - id: log_export
    type: io.kestra.plugin.ee.core.log.LogShipper
    logLevelFilter: INFO
    lookbackPeriod: P1D
    logExporters:
      - id: GCPLogExporter
        type: io.kestra.plugin.ee.gcp.gcs.LogExporter
        projectId: myProjectId
        format: JSON
        maxLinesPerFile:10000
        bucket: my-bucket
        logFilePrefix: kestra-log-file
        chunk: 1000

bucket*string

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

type*object

chunkintegerstring

Default1000

formatstring

DefaultJSON

Possible Values

IONJSON

impersonatedServiceAccountstring

logFilePrefixstring

Defaultkestra-log-file

maxLinesPerFileintegerstring

Default100000

projectIdstring

scopesarray

SubTypestring

Default["https://www.googleapis.com/auth/cloud-platform"]

serviceAccountstring

Send logs to Google Cloud Logging

Example

yaml
id: log_shipper
namespace: company.team

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

tasks:
  - id: log_export
    type: io.kestra.plugin.ee.core.log.LogShipper
    logLevelFilter: INFO
    batchSize: 1000
    lookbackPeriod: P1D
    logExporters:
      - id: GCPLogExporter
        type: io.kestra.plugin.ee.gcp.operationalsuite.LogExporter
        projectId: myProjectId

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

type*object

chunkintegerstring

Default1000

impersonatedServiceAccountstring

projectIdstring

scopesarray

SubTypestring

Default["https://www.googleapis.com/auth/cloud-platform"]

serviceAccountstring

Send logs to Splunk HEC

Example

yaml
id: log_shipper
namespace: company.team

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

tasks:
  - id: log_export
    type: io.kestra.plugin.ee.core.log.LogShipper
    logLevelFilter: INFO
    batchSize: 1000
    lookbackPeriod: P1D
    logExporters:
      - id: SplunkLogExporter
        type: io.kestra.plugin.ee.splunk.LogExporter
        host: YOUR_HOST
        token: "{{ secret('SPLUNK_TOKEN') }}"

host*string

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

token*string

type*object

chunkintegerstring

Default1000

options

io.kestra.core.http.client.configurations.HttpConfiguration

allowFailedbooleanstring

Defaultfalse

allowedResponseCodesarray

SubTypeinteger

auth

io.kestra.core.http.client.configurations.BasicAuthConfiguration

type*object

passwordstring

usernamestring

io.kestra.core.http.client.configurations.BearerAuthConfiguration

type*object

tokenstring

io.kestra.core.http.client.configurations.DigestAuthConfiguration

type*object

passwordstring

usernamestring

basicAuthPasswordstring

basicAuthUserstring

connectTimeoutstring

Formatduration

connectionPoolIdleTimeoutstring

Formatduration

defaultCharsetstring

DefaultUTF-8

java.nio.charset.Charset

followRedirectsbooleanstring

Defaulttrue

logLevelstring

Possible Values

ALLTRACEDEBUGINFOWARNERROROFFNOT_SPECIFIED

logsarray

SubTypestring

Possible Values

REQUEST_HEADERSREQUEST_BODYRESPONSE_HEADERSRESPONSE_BODY

maxContentLengthinteger

proxy

io.kestra.core.http.client.configurations.ProxyConfiguration

addressstring

passwordstring

portintegerstring

typestring

DefaultDIRECT

Possible Values

DIRECTHTTPSOCKS

usernamestring

proxyAddressstring

proxyPasswordstring

proxyPortinteger

proxyTypestring

Possible Values

DIRECTHTTPSOCKS

proxyUsernamestring

readIdleTimeoutstring

Formatduration

readTimeoutstring

Formatduration

ssl

io.kestra.core.http.client.configurations.SslOptions

insecureTrustAllCertificatesbooleanstring

timeout

io.kestra.core.http.client.configurations.TimeoutConfiguration

connectTimeoutstring

readIdleTimeoutstring

DefaultPT5M

sourcestring

DefaultKestra

Export execution logs to OpenSearch

Example

yaml
id: log_shipper
namespace: company.team

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

tasks:
  - id: logSync
    type: io.kestra.plugin.ee.core.log.LogShipper
    logLevelFilter: INFO
    batchSize: 1000
    lookbackPeriod: P1D
    logExporters:
      - id: OpensearchLogExporter
        type: io.kestra.plugin.ee.opensearch.LogExporter
        connection:
          hosts:
            - "http://localhost:9200/"
        indexName: "logs"

connection*

io.kestra.plugin.ee.opensearch.OpensearchConnection

hosts*array

SubTypestring

basicAuth

io.kestra.plugin.ee.opensearch.OpensearchConnection-BasicAuth

passwordstring

usernamestring

headersarray

SubTypestring

pathPrefixstring

strictDeprecationModebooleanstring

trustAllSslbooleanstring

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

indexName*string

type*object

chunkintegerstring

Default1000

Send logs to New Relic Logs API

Example

yaml
id: log_shipper
namespace: company.team

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

tasks:
  - id: log_export
    type: io.kestra.plugin.ee.core.log.LogShipper
    logLevelFilter: INFO
    batchSize: 1000
    lookbackPeriod: P1D
    logExporters:
      - id: NewRelicLogExporter
        type: io.kestra.plugin.ee.newrelic.LogExporter
        basePath: https://log-api.newrelic.com

apiKey*string

basePath*string

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

type*object

chunkintegerstring

Default1000

options

io.kestra.core.http.client.configurations.HttpConfiguration

allowFailedbooleanstring

Defaultfalse

allowedResponseCodesarray

SubTypeinteger

auth

io.kestra.core.http.client.configurations.BasicAuthConfiguration

type*object

passwordstring

usernamestring

io.kestra.core.http.client.configurations.BearerAuthConfiguration

type*object

tokenstring

io.kestra.core.http.client.configurations.DigestAuthConfiguration

type*object

passwordstring

usernamestring

basicAuthPasswordstring

basicAuthUserstring

connectTimeoutstring

Formatduration

connectionPoolIdleTimeoutstring

Formatduration

defaultCharsetstring

DefaultUTF-8

java.nio.charset.Charset

followRedirectsbooleanstring

Defaulttrue

logLevelstring

Possible Values

ALLTRACEDEBUGINFOWARNERROROFFNOT_SPECIFIED

logsarray

SubTypestring

Possible Values

REQUEST_HEADERSREQUEST_BODYRESPONSE_HEADERSRESPONSE_BODY

maxContentLengthinteger

proxy

io.kestra.core.http.client.configurations.ProxyConfiguration

addressstring

passwordstring

portintegerstring

typestring

DefaultDIRECT

Possible Values

DIRECTHTTPSOCKS

usernamestring

proxyAddressstring

proxyPasswordstring

proxyPortinteger

proxyTypestring

Possible Values

DIRECTHTTPSOCKS

proxyUsernamestring

readIdleTimeoutstring

Formatduration

readTimeoutstring

Formatduration

ssl

io.kestra.core.http.client.configurations.SslOptions

insecureTrustAllCertificatesbooleanstring

timeout

io.kestra.core.http.client.configurations.TimeoutConfiguration

connectTimeoutstring

readIdleTimeoutstring

DefaultPT5M

Send flow logs to Datadog Logs

Example

yaml
id: logShipper
namespace: company.team

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

tasks:
  - id: log_export
    type: io.kestra.plugin.ee.core.log.LogShipper
    logLevelFilter: INFO
    batchSize: 1000
    lookbackPeriod: P1D
    logExporters:
      - id: DatadogLogExporter
        type: io.kestra.plugin.ee.datadog.LogExporter
        basePath: https://http-intake.logs.datadoghq.eu
        apiKey: b96c7528f0aab740e8c4bcbe3a5c73a7

apiKey*string

basePath*string

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

type*object

chunkintegerstring

Default1000

options

io.kestra.core.http.client.configurations.HttpConfiguration

allowFailedbooleanstring

Defaultfalse

allowedResponseCodesarray

SubTypeinteger

auth

io.kestra.core.http.client.configurations.BasicAuthConfiguration

type*object

passwordstring

usernamestring

io.kestra.core.http.client.configurations.BearerAuthConfiguration

type*object

tokenstring

io.kestra.core.http.client.configurations.DigestAuthConfiguration

type*object

passwordstring

usernamestring

basicAuthPasswordstring

basicAuthUserstring

connectTimeoutstring

Formatduration

connectionPoolIdleTimeoutstring

Formatduration

defaultCharsetstring

DefaultUTF-8

java.nio.charset.Charset

followRedirectsbooleanstring

Defaulttrue

logLevelstring

Possible Values

ALLTRACEDEBUGINFOWARNERROROFFNOT_SPECIFIED

logsarray

SubTypestring

Possible Values

REQUEST_HEADERSREQUEST_BODYRESPONSE_HEADERSRESPONSE_BODY

maxContentLengthinteger

proxy

io.kestra.core.http.client.configurations.ProxyConfiguration

addressstring

passwordstring

portintegerstring

typestring

DefaultDIRECT

Possible Values

DIRECTHTTPSOCKS

usernamestring

proxyAddressstring

proxyPasswordstring

proxyPortinteger

proxyTypestring

Possible Values

DIRECTHTTPSOCKS

proxyUsernamestring

readIdleTimeoutstring

Formatduration

readTimeoutstring

Formatduration

ssl

io.kestra.core.http.client.configurations.SslOptions

insecureTrustAllCertificatesbooleanstring

timeout

io.kestra.core.http.client.configurations.TimeoutConfiguration

connectTimeoutstring

readIdleTimeoutstring

DefaultPT5M

servicestring

DefaultLogExporter

sourcestring

DefaultKestra

Send execution logs to Graylog

Example

yaml
id: log_shipper
namespace: company.team

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"

tasks:
  - id: log_export
    type: io.kestra.plugin.ee.core.log.LogShipper
    logLevelFilter: INFO
    lookbackPeriod: P1D
    logExporters:
      - id: GraylogExporter
        type: io.kestra.plugin.ee.graylog.LogExporter
        endpoint: "http://localhost:12201/gelf"
        graylogHost: "Kestra"
        chunk: 1000

endpoint*string

id*string

Validation RegExp^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length1

type*object

chunkintegerstring

Default1000

graylogHoststring

DefaultKestra

options

io.kestra.core.http.client.configurations.HttpConfiguration

allowFailedbooleanstring

Defaultfalse

allowedResponseCodesarray

SubTypeinteger

auth

io.kestra.core.http.client.configurations.BasicAuthConfiguration

type*object

passwordstring

usernamestring

io.kestra.core.http.client.configurations.BearerAuthConfiguration

type*object

tokenstring

io.kestra.core.http.client.configurations.DigestAuthConfiguration

type*object

passwordstring

usernamestring

basicAuthPasswordstring

basicAuthUserstring

connectTimeoutstring

Formatduration

connectionPoolIdleTimeoutstring

Formatduration

defaultCharsetstring

DefaultUTF-8

java.nio.charset.Charset

followRedirectsbooleanstring

Defaulttrue

logLevelstring

Possible Values

ALLTRACEDEBUGINFOWARNERROROFFNOT_SPECIFIED

logsarray

SubTypestring

Possible Values

REQUEST_HEADERSREQUEST_BODYRESPONSE_HEADERSRESPONSE_BODY

maxContentLengthinteger

proxy

io.kestra.core.http.client.configurations.ProxyConfiguration

addressstring

passwordstring

portintegerstring

typestring

DefaultDIRECT

Possible Values

DIRECTHTTPSOCKS

usernamestring

proxyAddressstring

proxyPasswordstring

proxyPortinteger

proxyTypestring

Possible Values

DIRECTHTTPSOCKS

proxyUsernamestring

readIdleTimeoutstring

Formatduration

readTimeoutstring

Formatduration

ssl

io.kestra.core.http.client.configurations.SslOptions

insecureTrustAllCertificatesbooleanstring

timeout

io.kestra.core.http.client.configurations.TimeoutConfiguration

connectTimeoutstring

readIdleTimeoutstring

DefaultPT5M

delete booleanstring

lookbackPeriod string

DefaultP1D

namespace string

offsetKey string

resources array

SubTypestring

Possible Values

AUDITLOGAPPASSETAPP_EXECUTIONBLUEPRINTBINDINGDASHBOARDEXECUTIONFLOWKILL_SWITCHKV_STOREGROUPINVITATIONNAMESPACENAMESPACE_FILEROLESECURITY_INTEGRATIONSECRETSETTINGTEMPLATETRIGGERTENANTTENANT_ACCESSTESTSUITETESTSUITE_RUNVERSIONED_PLUGINUSERCREDENTIALWORKER_GROUPINSTANCEUNKNOWN

Outputs

endFetchedDate string

Formatdate-time

outputs object

Definitions

io.kestra.core.models.tasks.Output

size integer

Export Kestra audit logs as a CSV file and send out via Email.

Execute R scripts as part of Kestra data workflows.

Kestra Plugin Transformation for records.

Execute Bun scripts as part of Kestra data workflows.

AuditLogShipper

Forward workflow audit logs to one or more desired destinations.

Create automations with Core Log Ee AuditLogShipper

Export Kestra audit logs as a CSV file and send out via Email.

More Plugins in this Category

1.3.5

AuditLogShipper Forward workflow audit logs to one or more desired destinations.

Create automations with Core Log Ee AuditLogShipper

Export Kestra audit logs as a CSV file and send out via Email.

More Plugins in this Category

1.3.5

AuditLogShipper

Forward workflow audit logs to one or more desired destinations.