dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

remove create database

This commit is contained in:
arthtux 2016-06-23 15:47:18 -04:00
parent f62c493c77
commit 4f5ad22113
1 changed files with 0 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
plugins/outputs/influxdb/influxdb.go
View File

@ -127,13 +127,6 @@ func (i *InfluxDB) Connect() error {
if err != nil { if err != nil {
return err return err
} }
err = createDatabase(c, i.Database)
if err != nil {
log.Println("Database creation failed: " + err.Error())
continue
}
conns = append(conns, c) conns = append(conns, c)
} }
} }
@ -143,14 +136,6 @@ func (i *InfluxDB) Connect() error {
return nil return nil
} }
func createDatabase(c client.Client, database string) error {
// Create Database if it doesn't exist
_, err := c.Query(client.Query{
Command: fmt.Sprintf("CREATE DATABASE IF NOT EXISTS \"%s\"", database),
})
return err
}
func (i *InfluxDB) Close() error { func (i *InfluxDB) Close() error {
var errS string var errS string
for j, _ := range i.conns { for j, _ := range i.conns {
@ -202,13 +187,6 @@ func (i *InfluxDB) Write(metrics []telegraf.Metric) error {
if e := i.conns[n].Write(bp); e != nil { if e := i.conns[n].Write(bp); e != nil {
// Log write failure // Log write failure
log.Printf("ERROR: %s", e) log.Printf("ERROR: %s", e)
// If the database was not found, try to recreate it
if strings.Contains(e.Error(), "database not found") {
if errc := createDatabase(i.conns[n], i.Database); errc != nil {
log.Printf("ERROR: Database %s not found and failed to recreate\n",
i.Database)
}
}
} else { } else {
err = nil err = nil
break break