Skip to main content

Striim Platform 5.0 documentation

Create a Jira Reader application

Create an app using a wizard

Sample TQL for Jira Reader

The following TQL creates an application that reads issues from the Jira instance and writes the data to BigQuery.

CREATE OR REPLACE APPLICATION jiraTest RECOVERY 10 SECOND INTERVAL;
CREATE OR REPLACE SOURCE jiraReaderTest USING JiraReader(
adapterName: 'JiraReader',
AuthMode: ‘OAuth',
EndpointUrl: 'https://webaction.atlassian.net/',
IncrementalLoadMarker: 'Id',
MigrateSchema: true,
Mode: 'InitialLoad',
PollingInterval: '10s',
ClientId: ‘<client_id>',
ClientSecret: ‘<client_secret>',
RefreshToken: ‘<refresh_token',
startPosition: '%=-1',
Tables: 'issues'
) OUTPUT TO jiraoutStream;


CREATE TARGET jirasys USING Global.SysOut (
name: ‘jirasys' )
INPUT FROM jiraoutStream;

CREATE OR REPLACE TARGET jiraBQWriter USING Global.BigQueryWriter (
ColumnDelimiter: '|',
NullMarker: 'NULL',
streamingUpload: 'false',
projectId: 'striimdev',
Encoding: 'UTF-8',
Tables: ‘%,JIRATEST.%',
ConnectionRetryPolicy: 'totalTimeout=600, initialRetryDelay=10,
retryDelayMultiplier=2.0, maxRetryDelay=60, maxAttempts=5, jittered=True,
initialRpcTimeout=10, rpcTimeoutMultiplier=2.0, maxRpcTimeout=30',
AllowQuotedNewLines: 'false',
CDDLAction: 'Process',
optimizedMerge: 'false',
TransportOptions: 'connectionTimeout=300, readTimeout=120',
adapterName: 'BigQueryWriter',
ServiceAccountKey: 'Platform/UploadedFiles/admin/google-gcs.json',
StandardSQL: 'true',
includeInsertId: 'true',
StreamingConfiguration: 'MaxRequestSizeInMB=5, MaxParallelRequests=5,
ApplicationCreatedStreamMode=None,
UseLegacyStreamingAPI=false',
QuoteCharacter: '\"',
Mode: 'MERGE',
DataLocation: 'US',
BatchPolicy: 'eventCount:1000, Interval:30' )
INPUT FROM jiraoutStream;

END APPLICATION