go - 将多个文件传递给存储桶中的 exec.Command 调用

Question

我正在尝试构建一个用 Go 编写的云函数，它将使用 Google 的 Cloud Functions 基础架构中可用的 ImageMagick 库来将多个图像合成并处理成最终的输出图像。

问题的根源是我想使用的 ImageMagick 函数可用，但它需要多个不同的输入才能工作。我的输入是存储桶中的对象。

os/exec Cmd 结构允许您通过使用“ExtraFiles”数组来执行此操作，而且我知道如何将这些额外文件提供给我的 ImageMagick 命令。

但是，“ExtraFiles”数组只想存储 os.File 的实例，而 GCP Storage Client 在您打开文件时会为您提供一个“Reader”实例。

        backgroundBlob := storageClient.Bucket(inputBucket).Object(background)
        backgroundImg, err := backgroundBlob.NewReader(ctx)
        if err != nil {
                return "", fmt.Errorf("backgroundImg: %v", err)
        }

        foregroundBlob := storageClient.Bucket(inputBucket).Object(foreground)
        foregroundImg, err := foregroundBlob.NewReader(ctx)
        if err != nil {
                return "", fmt.Errorf("foregroundImg: %v", err)
        }

        outputBlob := storageClient.Bucket(outputBucket).Object(output)
        outputImg := outputBlob.NewWriter(ctx)
        defer outputImg.Close()

        // Set up some additional file handles since we're dealing with more inputs than STDIN Can cope with
        cmd := exec.Command("convert", "fd:3", "fd:4", "-composite", "fd:5")
        cmd.ExtraFiles = append(cmd.ExtraFiles,backgroundImg)
        cmd.ExtraFiles = append(cmd.ExtraFiles,foregroundImg)
        cmd.ExtraFiles = append(cmd.ExtraFiles,outputImg)

        if err := cmd.Run(); err != nil {
                return "", fmt.Errorf("cmd.Run: %v", err)
        }

        log.Printf("Blurred image has been uploaded to %s", outputBlob.ObjectName())

        return outputBlob.ObjectName(), nil
}```

So, from where I am at the moment, I need to do one of the following two things:
1. Figure out how to get Google's storage API to treat/use objects in their storage buckets as "os.File"s
OR
2. Figure out how to execute my "convert" command using multiple Readers as input, rather than leveraging the ExtraFiles array.

If anybody out there has any ideas on how to achieve either of the above, or has alternate ways of solving this problem, I would be very grateful to hear them!

Answer 1

对于以后遇到这个问题的任何人 - 我找到了解决方法。我对它并不满意，但它很实用。

基本上，我能够读取存储读取器的内容，然后在 Cloud Functions 上下文中创建我自己的 os.File 对象。然后，将该 os.File 传递给 exec.Cmd 调用。这绝对不理想，但这是代码:

func Overlay(ctx context.Context, inputBucket, outputBucket, background string, foreground string, output string) (string, error) {
        // Retrieve the Background Image from the storage API
        backgroundBlob := storageClient.Bucket(inputBucket).Object(background)
        backgroundImg, err := backgroundBlob.NewReader(ctx)
        if err != nil {
                return "", fmt.Errorf("backgroundImg: %v", err)
        }        
        // Read the contents of the file into a variable
        backgroundSlurp, err := ioutil.ReadAll(backgroundImg)
        if err != nil {
                return "", fmt.Errorf("readFile: unable to read data from bucket %q, file %q: %v", inputBucket, background, err)
        }
        // Write the contents of Background Image to an os.File instance
        err = ioutil.WriteFile(fmt.Sprintf("/tmp/%s",background), backgroundSlurp, 0644)
        if err != nil {
                return "", fmt.Errorf("backgroundImg: %v", err)
        }
        // Open the os.File instance to pass it on to os.exec later
        backgroundFile, err := os.Open(fmt.Sprintf("/tmp/%s",background))
        if err != nil {
                return "", fmt.Errorf("backgroundFile: %v", err)
        }

        foregroundBlob := storageClient.Bucket(inputBucket).Object(foreground)
        foregroundImg, err := foregroundBlob.NewReader(ctx)
        if err != nil {
                return "", fmt.Errorf("foregroundImg: %v", err)
        }
        // Read the contents of the file into a variable
        foreroundSlurp, err := ioutil.ReadAll(foregroundImg)
        if err != nil {
                return "", fmt.Errorf("readFile: unable to read data from bucket %q, file %q: %v", inputBucket, foreground, err)
        }
        // Write the contents of Foreground Image to an os.File instance
        err = ioutil.WriteFile(fmt.Sprintf("/tmp/%s",foreground), foreroundSlurp, 0644)
        if err != nil {
                return "", fmt.Errorf("foregroundImg: %v", err)
        }
        // Open the os.File instance to pass it on to os.exec later
        foregroundFile, err := os.Open(fmt.Sprintf("/tmp/%s",foreground))
        if err != nil {
                return "", fmt.Errorf("foregroundFile: %v", err)
        }

        outputBlob := storageClient.Bucket(outputBucket).Object(output)
        outputImg := outputBlob.NewWriter(ctx)
        defer outputImg.Close()

        // Set up some additional file handles since we're delaqing with more inputs than STDIN Can cope with
        cmd := exec.Command("convert", "fd:3", "fd:4", "-composite", "-")
        cmd.Stdout = outputImg
        cmd.ExtraFiles = append(cmd.ExtraFiles,backgroundFile)
        cmd.ExtraFiles = append(cmd.ExtraFiles,foregroundFile)

        if err := cmd.Run(); err != nil {
                return "", fmt.Errorf("cmd.Run: %v", err)
        }

        log.Printf("Blurred image has been uploaded to %s", outputBlob.ObjectName())

        return outputBlob.ObjectName(), nil
}