3dshow-supplier/3dshow-supplier/funcgraph/tile360.go

package funcgraph

import (
	"3dshow-supplier/conf"
	"fmt"
	"strings"

	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
	functiongraph "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/functiongraph/v2"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/functiongraph/v2/model"
	region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/functiongraph/v2/region"
)

const (
	ak = "RA1D7CFVCVKUFX1FHHPB"
	sk = "cDrR2NgAF2KaA4MRkcK19r93P3P6hLKOPhHvPu9p"
)

func createFuncGraphClient() *functiongraph.FunctionGraphClient {
	auth := basic.NewCredentialsBuilder().
		WithAk(ak).
		WithSk(sk).
		Build()
	return functiongraph.NewFunctionGraphClient(
		functiongraph.FunctionGraphClientBuilder().
			WithRegion(region.ValueOf("cn-east-3")).
			WithCredential(auth).
			Build())

}

func Tile360onvRequest(assetId string, groupId string, sourcePath string, natsUrl string) error {

	ConvStreamTopic := conf.AppConfig.Nats.TileConvStreamTopic
	streamTopics := strings.Split(ConvStreamTopic, "#")

	client := createFuncGraphClient()

	request := &model.AsyncInvokeFunctionRequest{Body: map[string]interface{}{
		"groupId":    groupId,
		"assetId":    assetId,
		"sourcePath": sourcePath,

		"notifyNatsUrl": natsUrl,
		"notifyStream":  streamTopics[0],
		"notifySubject": streamTopics[1],
	}}

	request.FunctionUrn = "urn:fss:cn-east-3:0956c65fd600f29f2ff6c00dbb3d1e2e:function:default:osgconv:v1"
	response, err := client.AsyncInvokeFunction(request)

	if err == nil {
		fmt.Printf("%+v\n", response)
		return nil
	}
	fmt.Println(err)

	return err
}