将第二个孩子添加到主管会引发错误



我想给我的主管添加第二个孩子,但我得到了以下错误。

**(Mix(无法启动应用程序cloner_worker:已退出:ClonerWorker.application.start(:normal,[](**(EXIT(引发异常:**(ArgumentError(模块ClonerWorker.Worker作为子级提供给了主管,但它不存在。(长生不老药1.11.2(库/监督者。例如:631:监督者.init_child/1(elixir 1.11.2(lib/enum.ex:1399:enum&quot-map/2列表^map/1-0-"/2.(长生不老药1.11.2(lib/监督者。例如:617:监督者.init/2(elixir 1.11.2(库/主管。例如:556:主管.start_link/2(内核7.1(application_master.erl:277::application_master.start_it_old/4

application.ex

defmodule ClonerWorker.Application do
@moduledoc false
use Application
import Supervisor.Spec

def start(_type, _args) do
genconsumer_impl = ClonerWorker
genconsumer_group_name = "cloners"
genconsumer_group_opts = []
topic_names = ["todo-chunks"]
children = [
# this is the child that is throwing the error
{ClonerWorker.Worker, []},
supervisor(
KafkaEx.ConsumerGroup,
[genconsumer_impl,genconsumer_group_name,topic_names,genconsumer_group_opts]
)
]
opts = [strategy: :one_for_one, name: ClonerWorker.Supervisor]
Supervisor.start_link(children, opts)
end
end

工人(除外(

defmodule ClonerWorker.Worker do
use GenServer
use Tesla
require Logger
@base_url "https://poloniex.com/public?command=returnTradeHistory"
def start_link(args) do
GenServer.start_link(__MODULE__, args, name:__MODULE__)
end
def init(args) do
{:ok, args}
end
def get_history_for(currency_pair, from_unix, until_unix) do
from_unix = from_unix * 1000
until_unix = until_unix * 1000
url = "#{url}&currencyPair=#{currency_pair}&start=#{from_unix}&end=#{until_unix}"
result = send_request(url)
if (Enum.count(result) < 1000) do
Logger.info("Result is lesser than 1000")
for item <- result do
IO.inspect(item)
end
else
Logger.warn("Result is greater than 1000")
end
end
defp send_request(url) do
timestamp = DateTime.to_unix(DateTime.utc_now())
key = Application.get_env(:cloner_worker,:key)
secret = Application.get_env(:cloner_worker,:secret)
passphrase = Application.get_env(:cloner_worker,:passphrase)
sign = sign(key,timestamp,url)
headers = [{"PF-API-KEY",key},
{"PF-API-SIGN",sign},
{"PF-API-TIMESTAMP",timestamp},
{"PF-API-PASSPHRASE", passphrase}]
{:ok, result} = Tesla.get(url,headers)
Logger.info(result.status)
result = Jason.decode!(result.body)
end
defp sign(key, timestamp, endpoint, method \ "GET", body \ "") do
value = "#{timestamp}#{method}#{endpoint}#{body}"
:crypto.hmac(:sha256, key,value) |> Base.encode64
end
end

我知道类似的问题已经被问过了,但我在找不到解决问题的方法

提前感谢你能给我的任何帮助。

问题是我调用了我的文件worker.exs而不是worker.ex很抱歉在问题中存在误解,我确实将worker.ex放在了

相关内容

最新更新