Я использую symfony3 с armetiz / LeezyPheanstalkBundle.
Я хочу предварительно создать работу, которая создает таблицу с заданным именем. Я уже создал команду symfony create: table с именем аргумента, которая создает таблицу, если я запускаю из консоли bin / console create: таблица test_table. Теперь я хочу перейти на работу, используя phenastalk, когда мое событие запущено. Событие работает нормально, даже данные отправляются в трубу, но команда не выполняется. В чем проблема?
Это данные:
$payload = ["name" => $power_plant->getName()];
$jobData = ["command" => "create:table", "meta" => $payload];
Я установил название трубки
$this->pheanstalk->useTube($this->tubeName);
Я положил полезную нагрузку в трубу:
$this->pheanstalk->put(json_encode($jobData));
$this->pheanstalk->watch($this->tubeName)->ignore('default')->reserve();
Вот данные, которые я вижу в трубе:
{
"command":"create:table",
"meta":{
"name":"abc123"}
}
Но таблица не создается, но если я запускаю команду из консоли, таблица создается, поэтому команда в порядке. Я полагаю, что-то не так с работником pheanstalk?
Задача ещё не решена.
Других решений пока нет …