google storage event based source Google Storage Event-based Source

Provided by: "Apache Software Foundation"

Support Level for this Kamelet is: "Preview"

Receive data from Google Pubsub reporting events related to a Google Storage bucket.

Service account key is the basic method for authenticating to the Google Pubsub and Google Storage.

To use this Kamelet you’ll need to set up Events notification for your Google Storage Bucket.

You must encode the serviceAccountKey property before you pass it as a parameter.

Configuration Options

The following table summarizes the configuration options available for the google-storage-event-based-source Kamelet:

Property Name Description Type Default Example

bucketNameOrArn

Bucket Name Or ARN

Required The Google Cloud Storage bucket name or Bucket Amazon Resource Name (ARN).

string

projectId

Project Id

Required The Google Cloud Pub/Sub Project ID.

string

serviceAccountKey

Service Account Key

Required The service account key to use as credentials for the Pub/Sub publisher/subscriber. You must encode this value in base64.

binary

subscriptionName

Subscription Name

Required The subscription name.

string

concurrentConsumers

Concurrent Consumers

The number of parallel streams to consume from the subscription.

integer

1

getObject

Get Object in Bucket

If getObject is enabled, then the file created in the Bucket will be get and returned as body, if not only the event will be returned as body.

boolean

false

maxMessagesPerPoll

Max Messages Per Poll

The maximum number of messages to receive from the server in a single API call.

integer

1

synchronousPull

Synchronous Pull

Specifies to synchronously pull batches of messages.

boolean

false

Dependencies

At runtime, the google-storage-event-based-source Kamelet relies upon the presence of the following dependencies:

  • camel:kamelet

  • camel:google-pubsub

  • camel:google-storage

  • camel:jackson

  • camel:core

Camel JBang usage

Prerequisites

  • You’ve installed JBang.

  • You have executed the following command:

jbang app install camel@apache/camel

Supposing you have a file named route.yaml with this content:

- route:
    from:
      uri: "kamelet:google-storage-event-based-source"
      parameters:
        .
        .
        .
      steps:
        - to:
            uri: "kamelet:log-sink"

You can now run it directly through the following command

camel run route.yaml

Kamelet source file

https://github.com/apache/camel-kamelets/blob/main/kamelets/google-storage-event-based-source.kamelet.yaml

Back to top