我将自己的云功能部署到GCP。在云功能上,我启用了使用Google服务帐户进行身份验证的功能。我需要编写Golang代码来调用此云函数。我已经用Node.js达到了相同的目的,但无法使Golang正常工作。
这是我的Nodejs代码(正在运行):
const {GoogleAuth} = require('google-auth-library');
const targetAudience = "cloud-function-url"
async function run() {
const auth = new GoogleAuth();
const client = await auth.getIdTokenClient(targetAudience);
const res = await client.request({ url });
console.info(res.data);
}
我的Golang代码:
import "golang.org/x/oauth2/google"
func getToken() (err error) {
scope := "https://www.googleapis.com/auth/cloud-platform"
client, err := google.DefaultClient(context.Background(), scope)
if err != nil {
return
}
res, err := client.Get("cloud-function-url")
if err != nil {
return
}
fmt.Println(res)
return
}
我也尝试过自定义代码以添加targetAudience
,但它也不起作用
baseUrl := "your-cloudfunction-baseurl"
ctx := context.Background()
targetAudience := baseUrl
credentials, err := google.FindDefaultCredentials(ctx)
if err != nil {
fmt.Printf("cannot get credentials: %v", err)
os.Exit(1)
}
tokenSrc, err := google.JWTAccessTokenSourceFromJSON(credentials.JSON, targetAudience)
if err != nil {
fmt.Printf("cannot create jwt source: %v", err)
os.Exit(1)
}
client := oauth2.NewClient(context.Background(), tokenSrc)
if err != nil {
return
}
res, err := client.Get(baseUrl + "sub-url")
if err != nil {
return
}
我已经检查并确保我的服务帐户已正确加载。在上述两种情况下,我都收到401 "The access token could not be verified"
我编写了一个名为token-generator的开源应用。它在Go中,并且我生成了签名身份令牌,以便能够调用私有Cloud Run和Cloud Function。
随意使用它或复制您自己的应用程序所需的核心代码!!如果您愿意,我们可以在这里讨论或在GitHub上发布问题。
[深入研究Google's Oauth Protocol和OAuth2后,我发现Golang中的库未完全遵循Google的OAuth2协议。
令人惊讶的是,Nodejs库正确处理了流程,而Golang却没有。我将调查总结为blog post。
对于那些想要简短回答的人,这是我的实现(我将某些部分移到了公共仓库中:]
import (
"context"
"fmt"
"io/ioutil"
"os"
"github.com/CodeLinkIO/go-cloudfunction-auth/cloudfunction"
"golang.org/x/oauth2/google"
)
func main() {
baseUrl := "your-cloudfunction-baseurl"
ctx := context.Background()
targetAudience := baseUrl
credentials, err := google.FindDefaultCredentials(ctx)
if err != nil {
fmt.Printf("cannot get credentials: %v", err)
os.Exit(1)
}
jwtSource, err := cloudfunction.JWTAccessTokenSourceFromJSON(credentials.JSON, targetAudience)
if err != nil {
fmt.Printf("cannot create jwt source: %v", err)
os.Exit(1)
}
client := cloudfunction.NewClient(jwtSource)
res, err := client.Get(baseUrl + "/cloudfunction-sub-page")
if err != nil {
fmt.Printf("cannot fetch result: %v", err)
os.Exit(1)
}
defer res.Body.Close()
body, err := ioutil.ReadAll(res.Body)
if err != nil {
fmt.Printf("cannot read response: %v", err)
os.Exit(1)
}
println(string(body))
}