Голангский эквивалент создания подпроцесса в Python - PullRequest
0 голосов
/ 19 января 2019

Я пытаюсь преобразовать скрипт Python в Golang, просто чтобы увидеть разницу в производительности и помочь мне узнать Golang больше.

В Python у меня есть 2 скрипта.Одним из них является сценарий, который запускает бесконечный цикл и спит минуту перед повторным запуском.Код проверяет конечную точку на моем сервере и читает выходные данные, а затем определяет, нужно ли что-либо делать.Если это так, он обрабатывает вывод и запускает новый подпроцесс.Подпроцесс - это еще один скрипт Python, который выполняет много вычислений и создает сотни потоков.В каждый момент времени может быть запущено несколько подпроцессов, и все они являются разными задачами для разных пользователей.

У меня есть чтение кода Golang из API, и он готов начать новый подпроцесс.Но я не совсем уверен, как мне это сделать.

Я знаю, когда я создал новый подпроцесс (или что-то еще, что является эквивалентом Go), я могу создать кучу подпрограмм Go, но на самом деле я просто застрял в бите «подпроцесс».

Я пытался использовать подпрограммы Go вместо подпроцесса, но я не думаю, что это путь?

По запросу в целях визуализации я добавил пример кода.

api.py:

while True:
    someparameter = 'randomIDfromdatabase'
    subprocess.Popen(["python3", "mycode.py", someparameter])
    time.sleep(60)

mycode.py

parameter = sys.argv[1]
for i in range(0, 100):
    thread.append(MyClass(parameter))
    thread.start()

Мне в основном нужен Голанский эквивалент «subprocess.Popen».

1 Ответ

0 голосов
/ 19 января 2019

Вы можете использовать пакет Go os/exec для поведения, подобного подпроцессам.Например, вот тривиальная программа, которая запускает программу date в подпроцессе и сообщает о своем стандартном выводе:

package main

import (
    "fmt"
    "log"
    "os/exec"
)

func main() {
    out, err := exec.Command("date").Output()
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("The date is %s\n", out)
}

Более интересный пример из gobyexample , который показывает, как взаимодействовать сstdio / stdout запущенных процессов:

package main

import "fmt"
import "io/ioutil"
import "os/exec"

func main() {

    // We'll start with a simple command that takes no
    // arguments or input and just prints something to
    // stdout. The `exec.Command` helper creates an object
    // to represent this external process.
    dateCmd := exec.Command("date")

    // `.Output` is another helper that handles the common
    // case of running a command, waiting for it to finish,
    // and collecting its output. If there were no errors,
    // `dateOut` will hold bytes with the date info.
    dateOut, err := dateCmd.Output()
    if err != nil {
        panic(err)
    }
    fmt.Println("> date")
    fmt.Println(string(dateOut))

    // Next we'll look at a slightly more involved case
    // where we pipe data to the external process on its
    // `stdin` and collect the results from its `stdout`.
    grepCmd := exec.Command("grep", "hello")

    // Here we explicitly grab input/output pipes, start
    // the process, write some input to it, read the
    // resulting output, and finally wait for the process
    // to exit.
    grepIn, _ := grepCmd.StdinPipe()
    grepOut, _ := grepCmd.StdoutPipe()
    grepCmd.Start()
    grepIn.Write([]byte("hello grep\ngoodbye grep"))
    grepIn.Close()
    grepBytes, _ := ioutil.ReadAll(grepOut)
    grepCmd.Wait()

    // We ommited error checks in the above example, but
    // you could use the usual `if err != nil` pattern for
    // all of them. We also only collect the `StdoutPipe`
    // results, but you could collect the `StderrPipe` in
    // exactly the same way.
    fmt.Println("> grep hello")
    fmt.Println(string(grepBytes))

    // Note that when spawning commands we need to
    // provide an explicitly delineated command and
    // argument array, vs. being able to just pass in one
    // command-line string. If you want to spawn a full
    // command with a string, you can use `bash`'s `-c`
    // option:
    lsCmd := exec.Command("bash", "-c", "ls -a -l -h")
    lsOut, err := lsCmd.Output()
    if err != nil {
        panic(err)
    }
    fmt.Println("> ls -a -l -h")
    fmt.Println(string(lsOut))
}

Обратите внимание, что подпрограммы имеют мало общего с подпроцессами.Goroutines - это способ сделать несколько вещей одновременно в одном процессе Go .Тем не менее, при взаимодействии с подпроцессами часто нужны полезные процедуры, поскольку они помогают дождаться завершения подпроцессов, а также выполняют другие действия в запускающей (основной) программе.Но детали этого очень специфичны для вашего приложения.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...