-
Notifications
You must be signed in to change notification settings - Fork 1
/
main.go
44 lines (38 loc) · 1.16 KB
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
package main
import (
"flag"
"github.com/ibuilding-x/driver-box/driverbox"
"github.com/ibuilding-x/driver-box/driverbox/export"
"os"
)
func main() {
//localMode()
var broker string
var clientId string
var username string
var password string
var exportTopic string
flag.StringVar(&broker, "broker", os.Getenv("MQTT_BROKER"), "mqttExport: broker address")
flag.StringVar(&clientId, "clientId", os.Getenv("MQTT_CLIENT_ID"), "mqttExport: clientId")
flag.StringVar(&username, "username", os.Getenv("MQTT_USERNAME"), "mqttExport: username")
flag.StringVar(&password, "password", os.Getenv("MQTT_PASSWORD"), "mqttExport: password")
flag.StringVar(&exportTopic, "exportTopic", os.Getenv("MQTT_EXPORT_TOPIC"), "mqttExport: exportTopic")
flag.Parse()
// 设置日志级别
_ = os.Setenv("LOG_LEVEL", "debug")
if len(clientId) == 0 {
clientId = ""
}
driverbox.Start([]export.Export{&export.MqttExport{
Broker: broker,
ClientID: clientId,
Username: username,
Password: password,
ExportTopic: exportTopic,
}})
select {}
}
func localMode() {
_ = os.Setenv("MQTT_BROKER", "mqtt://127.0.0.1:1883")
_ = os.Setenv("MQTT_CLIENT_ID", "123456")
}