我正在构建一个Java Azure函数，我想连接到我的Cosmos数据库并在其中执行CRUD操作。无论我现在做什么，我都无法在运行函数时连接到数据库。如果我尝试使用@CosmosDBOutput和Document进行连接，我可以上传到数据库，但是我需要把函数分离出来。下面是我的主处理程序（使用@CosmosDBOutput和Document工作和上传）：

import java.util.*;
import com.microsoft.azure.functions.annotation.*;
import com.microsoft.azure.functions.*;
import com.microsoft.azure.documentdb.Document;

public class Handler {

    @FunctionName("HttpHandler")
    public HttpResponseMessage runHttp(
            @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS)
            HttpRequestMessage<Optional<String>> req, 
            @CosmosDBOutput(name = "database", databaseName = "hyperscalerapi-cosmos-dev", 
            collectionName = "Items", connectionStringSetting = "cosmosDBConnectionString")
            OutputBinding<String> outputItem, final ExecutionContext context) {
        try {
            
            // request to String (payload)
            String payload = req.getBody().get();

            Document document = new Document(payload);
            document.setId(context.getInvocationId().toString());
            outputItem.setValue(document.toString());
            context.getLogger().info("\nAdded payload: " + payload + 
                                    "\nWith ID: " + context.getInvocationId().toString() + "\nTo CosmosDB\n");
            
            return req.createResponseBuilder(HttpStatus.OK).body("Data logged").build();
        } catch (Exception e) {
            // log the exception
            context.getLogger().severe(e.toString());
            return req.createResponseBuilder(HttpStatus.INTERNAL_SERVER_ERROR).body("An error occurred").build();
        }
    }
}

下面是我要做的代码，其中包括处理程序以及我的CosmosOperation.java类，我正尝试使用该类连接到数据库：

import java.util.*;
import com.microsoft.azure.functions.annotation.*;
import com.microsoft.azure.functions.*;
import com.microsoft.azure.documentdb.Document;

public class Handler {

    @FunctionName("HttpHandler")
    public HttpResponseMessage runHttp(
            @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS)
            HttpRequestMessage<Optional<String>> req, final ExecutionContext context) {
        try {
            
            // request to String (payload)
            String payload = req.getBody().get();

            // Create in Cosmos
            CosmosOperation p = new CosmosOperation();
            p.create(payload, context);

            return req.createResponseBuilder(HttpStatus.OK).body("Data logged").build();
        } catch (Exception e) {
            // log the exception
            context.getLogger().severe(e.toString());
            return req.createResponseBuilder(HttpStatus.INTERNAL_SERVER_ERROR).body("An error occurred").build();
        }
    }
}

和CosmosOperation.java类：

import com.microsoft.azure.functions.annotation.*;
    import com.microsoft.azure.functions.*;
    import java.util.*;
    import java.util.logging.*;
    import com.azure.cosmos.*;
    import com.azure.cosmos.models.*;
    import com.azure.cosmos.util.CosmosPagedIterable;
    import com.microsoft.azure.documentdb.Document;
    //import com.azure.cosmos.examples.common.AccountSettings;
    
    /**
     * Azure Functions in Java with Cosmos DB Trigger.
     */
    public class CosmosOperation {
        public CosmosClient client;
        private final String databaseName = "hyperscalerapi-cosmos-dev";
        private CosmosDatabase database;
        public CosmosContainer container;
        private final String containerName = "Items";
    
        public CosmosOperation() {
            try {
                client = new CosmosClientBuilder()
                            .endpoint("This is where my CosmosDB endpoint is")
                            .key("This is where my CosmosDB Primary Key is")
                            .consistencyLevel(ConsistencyLevel.EVENTUAL)
                            .contentResponseOnWriteEnabled(true)
                            .buildClient();
            } catch (Exception e) {
                System.out.println("----------------------------------------------------------");
                System.out.println(e);
                System.out.println("----------------------------------------------------------");
            }
        }
    public void create(String payload, final ExecutionContext context) {
        container.createItem(payload, new PartitionKey(context.getInvocationId().toString()), new CosmosItemRequestOptions());
    }
}

这是我得到的主要错误。我知道端点和键是正确的，因为它们都在我在工作处理程序中使用的连接字符串中：

java.lang.RuntimeException: Client initialization failed. Check if the endpoint is reachable and if your auth token is valid. More info: https://aka.ms/cosmosdb-tsg-service-unavailable-java

然而，我也收到了其中的一些错误，但我认为它们目前并不重要：

java.lang.NoSuchMethodError: 'void io.netty.handler.codec.http.HttpClientCodec.<init>(int, int, int, boolean, boolean, int, boolean, boolean)'