Quarkus - Funqy Google Cloud Functions

    As the Google Cloud Function Java engine is a new Beta feature of Google Cloud, this extension is flagged as experimental.

    To complete this guide, you need:

    • less than 30 minutes

    • JDK 11 (Google Cloud Functions requires JDK 11)

    • Apache Maven 3.6.2+

    • A Google Cloud Account. Free accounts work.

    Login to Google Cloud

    Login to Google Cloud is necessary for deploying the application and it can be done as follows:

    At the time of this writing, Cloud Functions are still in beta so make sure to install the command group.

    1. gcloud components install beta

    The Quickstart

    Clone the Git repository: git clone [https://github.com/quarkusio/quarkus-quickstarts.git](https://github.com/quarkusio/quarkus-quickstarts.git), or download an archive.

    The solution is located in the funqy-google-cloud-functions-quickstart .

    Create an application with the quarkus-funqy-google-cloud-functions extension. You can use the following Maven command to create it:

    1. mvn io.quarkus:quarkus-maven-plugin:1.7.6.Final:create \
    2. -DprojectGroupId=org.acme \
    3. -DprojectArtifactId=funqy-google-cloud-functions \
    4. -DclassName="org.acme.quickstart.GreetingResource" \
    5. -Dpath="/hello" \

    Now, let’s remove what’s not needed inside the generated application:

    • Remove the dependency io.quarkus:quarkus-reasteasy from your pom.xml file.

    • Remove the generated org.acme.quickstart.GreetingResource class.

    • Remove the existing tests.

    The Code

    There is nothing special about the code and more importantly nothing Google Cloud specific. Funqy functions can be deployed to many different environments and Google Cloud Functions is one of them.

    Choose Your Function

    Only one Funqy function can be exported per Google Cloud Functions deployment. If you only have one method annotated with @Funq in your project, then there is no worries. If you have multiple functions defined within your project, then you will need to choose the function within your Quarkus application.properties:

    1. quarkus.funqy.export=greet

    Alternatively, you can set the QUARKUS_FUNQY_EXPORT environment variable when you create the Google Cloud Function using the gcloud cli.

    Build the project using maven.

    1. ./mvnw clean package

    This will compile and package your code.

    Create the function

    In this example, we will create two background functions. Background functions allow to react to Google Cloud events like PubSub messages, Cloud Storage events, Firestore events, …​

    1. import javax.inject.Inject;
    2. import io.quarkus.funqy.Funq;
    3. import io.quarkus.funqy.gcp.functions.event.PubsubMessage;
    4. import io.quarkus.funqy.gcp.functions.event.StorageEvent;
    5. public class GreetingFunctions {
    6. @Inject GreetingService service; (1)
    7. @Funq (2)
    8. public void helloPubSubWorld(PubsubMessage pubSubEvent) {
    9. String message = service.hello(pubSubEvent.data);
    10. System.out.println(pubSubEvent.messageId + " - " + message);
    11. }
    12. @Funq (3)
    13. public void helloGCSWorld(StorageEvent storageEvent) {
    14. String message = service.hello("world");
    15. System.out.println(storageEvent.name + " - " + message);
    16. }
    Function return type can also be Mutiny reactive types.
    1. Injection works inside your function.

    2. This is a background function that takes as parameter a io.quarkus.funqy.gcp.functions.event.PubsubMessage, this is a convenient class to deserialize a PubSub message.

    3. This is a background function that takes as parameter a io.quarkus.funqy.gcp.functions.event.StorageEvent, this is a convenient class to deserialize a Google Storage event.

    As our project contains multiple function, we need to specify which function needs to be deployed via the following property inside our application.properties :

    Build and Deploy to Google Cloud

    To build your application, you can package your application via mvn clean package. You will have a single JAR inside the target/deployment repository that contains your classes and all your dependencies in it.

    Then you will be able to use gcloud to deploy your function to Google Cloud, the gcloud command will be different depending from which event you want to be triggered.

    The first time you launch the gcloud beta functions deploy, you can have the following error message:

    1. ERROR: (gcloud.beta.functions.deploy) OperationError: code=7, message=Build Failed: Cloud Build has not been used in project <project_name> before or it is disabled. Enable it by visiting https://console.developers.google.com/apis/api/cloudbuild.googleapis.com/overview?project=<my-project&gt; then retry.

    This means that Cloud Build is not activated yet. To overcome this error, open the URL shown in the error, follow the instructions and then wait a few minutes before retrying the command.

    Use this command to deploy to Google Cloud Functions:

    1. gcloud beta functions deploy quarkus-example-funky-pubsub \
    2. --entry-point=io.quarkus.funqy.gcp.functions.FunqyBackgroundFunction \
    3. --runtime=java11 --trigger-resource hello_topic --trigger-event google.pubsub.topic.publish \
    4. --source=target/deployment

    The entry point always needs to be io.quarkus.funqy.gcp.functions.FunqyBackgroundFunction as it will be this class that will bootstrap Quarkus.

    The --trigger-resource option defines the name of the PubSub topic, and the --trigger-event google.pubsub.topic.publish option define that this function will be triggered by all message publication inside the topic.

    1. gcloud functions call quarkus-example-funky-pubsub --data '{"data":"Pub/Sub"}'

    The --data '{"data":"Hello, Pub/Sub"}' option allow to specify the message to be send to PubSub.

    Before deploying your function, you need to create a bucket.

    1. gsutil mb gs://quarkus-hello

    Then, use this command to deploy to Google Cloud Functions:

    1. gcloud beta functions deploy quarkus-example-funky-storage \
    2. --entry-point=io.quarkus.funqy.gcp.functions.FunqyBackgroundFunction \
    3. --runtime=java11 --trigger-resource quarkus-hello --trigger-event google.storage.object.finalize \
    4. --source=target/deployment

    The entry point always needs to be io.quarkus.funqy.gcp.functions.FunqyBackgroundFunction as it will be this class that will bootstrap Quarkus.

    The --trigger-resource option defines the name of the Cloud Storage bucket, and the --trigger-event google.storage.object.finalize option define that this function will be triggered by all new file inside this bucket.

    To trigger an event to this function, you can use the gcloud functions call command:

    The --data '{"name":"test.txt"}' option allow to specify a fake file name, a fake Cloud Storage event will be created for this name.

    You can also simply add a file to Cloud Storage using the command line of the web console.

    The easiest way to locally test your function is using the Cloud Function invoker JAR.

    You can download it via Maven using the following command:

    1. mvn dependency:copy \
    2. -Dartifact='com.google.cloud.functions.invoker:java-function-invoker:1.0.0-beta1' \
    3. -DoutputDirectory=.

    Before using the invoker, you first need to build your function via mvn package.

    Then you can use it to launch your function locally, again, the command depends on the type of function and the type of events.

    For background functions, you launch the invoker with a target class of io.quarkus.funqy.gcp.functions.FunqyBackgroundFunction.

    1. java -jar java-function-invoker-1.0.0-beta1.jar \
    2. --classpath target/funqy-google-cloud-functions-1.0.0-SNAPSHOT-runner.jar \
    3. --target io.quarkus.funqy.gcp.functions.FunqyBackgroundFunction

    Then you can call your background function via an HTTP call with a payload containing the event:

    1. curl localhost:8080 -d '{"data":{"data":"world"}}'

    This will call your PubSub background function with a PubSubMessage {"data":"hello"}.

    For background functions, you launch the invoker with a target class of io.quarkus.funqy.gcp.functions.FunqyBackgroundFunction.

    1. java -jar java-function-invoker-1.0.0-beta1.jar \
    2. --classpath target/funqy-google-cloud-functions-1.0.0-SNAPSHOT-runner.jar \
    3. --target io.quarkus.funqy.gcp.functions.FunqyBackgroundFunction
    The —classpath parameter needs to be set to the previously packaged JAR that contains your function class and all Quarkus related classes.

    Then you can call your background function via an HTTP call with a payload containing the event:

      This will call your PubSub background function with a Cloud Storage event {"name":"file.txt"}, so an event on the file.

      What’s next?