Skip to content

Commit 56c81f7

Browse files
ahmedmuhsinahmedmuhsin
authored
Merge branch 'dev' into dependabot/maven/io.grpc-grpc-netty-shaded-1.75.0
2 parents dd26671 + 5bb296a commit 56c81f7

21 files changed

Lines changed: 2177 additions & 39 deletions

‎.gitignore‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -281,3 +281,10 @@ obj/
281281

282282
# Certificate files (downloaded dynamically)
283283
confluent_cloud_cacert.pem
284+
285+
# Python compiled files
286+
*.pyc
287+
__pycache__/
288+
289+
# Environment configuration files
290+
.env

‎dockertests/.env.example‎

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,31 @@
1+
# Azure Functions Test Environment Configuration
2+
# Copy this file to .env and customize for your environment
3+
4+
# Runtime Configuration
5+
FUNCTIONS_TEST_RUNTIME=java
6+
FUNCTIONS_TEST_RUNTIME_VERSION=21
7+
FUNCTIONS_TEST_HOST_VERSION=4
8+
9+
# Worker Directory (optional)
10+
# Set this to mount a custom worker for development/testing
11+
# If not set, the container will use its built-in worker
12+
# Example: FUNCTIONS_TEST_WORKER_DIR=D:\path\to\azure-functions-java-worker\java
13+
FUNCTIONS_TEST_WORKER_DIR=
14+
15+
# App Directory (optional)
16+
# Directory containing app packages (.zip or .squashfs files)
17+
# Default: ./apps
18+
FUNCTIONS_TEST_APPS_DIR=./apps
19+
20+
# Storage Configuration (optional)
21+
# Use Azurite by default (true) or real Azure Storage (false)
22+
FUNCTIONS_TEST_USE_AZURITE=true
23+
24+
# Real Azure Storage Connection String (only needed if USE_AZURITE=false)
25+
# FUNCTIONS_TEST_STORAGE_CONNECTION_STRING=DefaultEndpointsProtocol=https;AccountName=...
26+
27+
# Notes:
28+
# - All parameters are optional and have sensible defaults
29+
# - Leave FUNCTIONS_TEST_WORKER_DIR empty to use the built-in worker from the image
30+
# - Set FUNCTIONS_TEST_WORKER_DIR to a path to mount your custom worker
31+

‎dockertests/app-src/BlobSdkType/host.json‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
{
2+
"version": "2.0",
3+
"extensionBundle": {
4+
"id": "Microsoft.Azure.Functions.ExtensionBundle",
5+
"version": "[4.*, 5.0.0)"
6+
}
7+
}

‎dockertests/app-src/BlobSdkType/pom.xml‎

Lines changed: 102 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,102 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0"
3+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5+
<modelVersion>4.0.0</modelVersion>
6+
7+
<groupId>com.microsoft.azure.samples</groupId>
8+
<artifactId>functions-quickstart-java-azd-eventgrid-blob</artifactId>
9+
<version>1.0.0</version>
10+
<packaging>jar</packaging>
11+
12+
<name>Azure Functions Java Event Grid Blob Trigger</name>
13+
<description>Azure Functions Java Event Grid Blob Trigger sample using Azure Developer CLI</description>
14+
15+
<properties>
16+
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
17+
<java.version>8</java.version>
18+
<maven.compiler.source>8</maven.compiler.source>
19+
<maven.compiler.target>8</maven.compiler.target>
20+
<azure.functions.maven.plugin.version>1.39.0</azure.functions.maven.plugin.version>
21+
<azure.functions.java.library.version>3.2.2</azure.functions.java.library.version>
22+
<azure.storage.blob.version>12.32.0</azure.storage.blob.version>
23+
<junit.version>5.10.1</junit.version>
24+
<functionAppName>functions-quickstart-java-azd-eventgrid-blob</functionAppName>
25+
</properties>
26+
27+
<dependencies>
28+
<dependency>
29+
<groupId>com.microsoft.azure.functions</groupId>
30+
<artifactId>azure-functions-java-library</artifactId>
31+
<version>${azure.functions.java.library.version}</version>
32+
</dependency>
33+
<dependency>
34+
<groupId>com.azure</groupId>
35+
<artifactId>azure-storage-blob</artifactId>
36+
<version>${azure.storage.blob.version}</version>
37+
</dependency>
38+
<!-- Test dependencies -->
39+
<dependency>
40+
<groupId>org.junit.jupiter</groupId>
41+
<artifactId>junit-jupiter</artifactId>
42+
<version>${junit.version}</version>
43+
<scope>test</scope>
44+
</dependency>
45+
<dependency>
46+
<groupId>org.slf4j</groupId>
47+
<artifactId>slf4j-simple</artifactId>
48+
<version>2.0.17</version>
49+
<scope>test</scope>
50+
</dependency>
51+
</dependencies>
52+
53+
<build>
54+
<plugins>
55+
<plugin>
56+
<groupId>org.apache.maven.plugins</groupId>
57+
<artifactId>maven-compiler-plugin</artifactId>
58+
<version>3.14.0</version>
59+
<configuration>
60+
<source>${java.version}</source>
61+
<target>${java.version}</target>
62+
</configuration>
63+
</plugin>
64+
<plugin>
65+
<groupId>com.microsoft.azure</groupId>
66+
<artifactId>azure-functions-maven-plugin</artifactId>
67+
<version>${azure.functions.maven.plugin.version}</version>
68+
<configuration>
69+
<appName>functions-quickstart-java-azd-eventgrid-blob</appName>
70+
<resourceGroup>rg-functions-quickstart-java</resourceGroup>
71+
<region>eastus</region>
72+
<runtime>
73+
<os>linux</os>
74+
<javaVersion>17</javaVersion>
75+
</runtime>
76+
<appSettings>
77+
<property>
78+
<name>FUNCTIONS_EXTENSION_VERSION</name>
79+
<value>~4</value>
80+
</property>
81+
</appSettings>
82+
</configuration>
83+
<executions>
84+
<execution>
85+
<id>package-functions</id>
86+
<goals>
87+
<goal>package</goal>
88+
</goals>
89+
</execution>
90+
</executions>
91+
</plugin>
92+
<plugin>
93+
<groupId>org.apache.maven.plugins</groupId>
94+
<artifactId>maven-surefire-plugin</artifactId>
95+
<version>3.5.3</version>
96+
<configuration>
97+
<useSystemClassLoader>false</useSystemClassLoader>
98+
</configuration>
99+
</plugin>
100+
</plugins>
101+
</build>
102+
</project>

‎dockertests/app-src/BlobSdkType/src/main/java/com/microsoft/azure/samples/ProcessBlobUpload.java‎

Lines changed: 64 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,64 @@
1+
package com.microsoft.azure.samples;
2+
3+
import com.microsoft.azure.functions.annotation.*;
4+
import com.microsoft.azure.functions.*;
5+
import com.azure.storage.blob.BlobContainerClient;
6+
import com.azure.storage.blob.BlobClient;
7+
8+
import java.util.Optional;
9+
import java.util.logging.Logger;
10+
11+
/**
12+
* Azure Functions with Event Grid Blob Trigger using SDK type bindings.
13+
*/
14+
public class ProcessBlobUpload {
15+
16+
private static final Logger classLogger = Logger.getLogger(ProcessBlobUpload.class.getName());
17+
18+
public ProcessBlobUpload() {
19+
String javaEnableSdkTypes = System.getenv("JAVA_ENABLE_SDK_TYPES");
20+
classLogger.info(String.format("ProcessBlobUpload class constructed. JAVA_ENABLE_SDK_TYPES environment variable value: %s",
21+
javaEnableSdkTypes != null ? javaEnableSdkTypes : "null (not set)"));
22+
}
23+
24+
@FunctionName("ProcessBlobUpload")
25+
@StorageAccount("AzureWebJobsStorage")
26+
public void run(
27+
@BlobTrigger(
28+
name = "sourceBlob",
29+
path = "unprocessed-pdf/{name}"
30+
) BlobClient sourceBlob,
31+
@BindingName("name") String blobName,
32+
@BlobInput(
33+
name = "outputBlobContainerClient",
34+
path = "processed-pdf"
35+
) BlobContainerClient outputBlobContainerClient,
36+
final ExecutionContext context) {
37+
38+
Logger logger = context.getLogger();
39+
40+
try {
41+
long blobSize = sourceBlob.getProperties().getBlobSize();
42+
logger.info(String.format("Java Blob Trigger processed blob\n Name: %s \n Size: %d bytes", blobName, blobSize));
43+
44+
// Copy the blob to the processed container with a new name
45+
String newBlobName = "processed-" + blobName;
46+
BlobClient outputBlob = outputBlobContainerClient.getBlobClient(newBlobName);
47+
48+
if (outputBlob.exists()) {
49+
logger.info(String.format("Blob %s already exists in the processed container. Skipping upload.", newBlobName));
50+
return;
51+
}
52+
53+
// Here you can add any processing logic for the input blob before uploading it to the processed container.
54+
55+
// Uploading the blob to the processed container using streams. You could add processing of the input stream logic here if needed.
56+
outputBlob.upload(sourceBlob.openInputStream(), true);
57+
logger.info(String.format("PDF processing complete for %s. Blob copied to processed container with new name %s.", blobName, newBlobName));
58+
59+
} catch (Exception error) {
60+
logger.severe(String.format("Error processing blob %s: %s", blobName, error.getMessage()));
61+
throw new RuntimeException(error);
62+
}
63+
}
64+
}

0 commit comments

Comments
 (0)