Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
S
saltstack
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Registry
Registry
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Chalermpong
saltstack
Commits
d37ae1df
Commit
d37ae1df
authored
Jun 12, 2024
by
Waruenada kenanan
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
add process.env
parent
e783e29a
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
29 additions
and
35 deletions
+29
-35
.env
+4
-2
index.js
+11
-19
saltdb_v2.js
+14
-14
No files found.
.env
View file @
d37ae1df
...
@@ -6,8 +6,10 @@ POSTGRES_PORT = 5432
...
@@ -6,8 +6,10 @@ POSTGRES_PORT = 5432
PGADMIN_DEFAULT_EMAIL = user@user
PGADMIN_DEFAULT_EMAIL = user@user
PGADMIN_DEFAULT_PASSWORD = password
PGADMIN_DEFAULT_PASSWORD = password
PGADMIN_PORT = 8888
PGADMIN_PORT = 8888
#SALT_USER = saltuser
SALT_URL = http://54.151.166.113:8000
#SALT_PASSWORD = password
SALT_USER = saltuser
SALT_PASSWORD = saltpassword
SALT_EAUTH = pam
CLOUDBEAVER_AUTH_PROXY_PROVIDER_URI=http://localhost:8978
CLOUDBEAVER_AUTH_PROXY_PROVIDER_URI=http://localhost:8978
CLOUDBEAVER_ADMIN_USERNAME=admin
CLOUDBEAVER_ADMIN_USERNAME=admin
CLOUDBEAVER_ADMIN_PASSWORD=admin
CLOUDBEAVER_ADMIN_PASSWORD=admin
...
...
index.js
View file @
d37ae1df
// import { Salt } from "salt-api";
const
{
Salt
}
=
require
(
"salt-api"
);
const
{
Salt
}
=
require
(
"salt-api"
);
const
pg
=
require
(
"pg"
);
const
pg
=
require
(
"pg"
);
const
saltdb_v2
=
require
(
"./saltdb_v2.js"
)
const
saltdb_v2
=
require
(
"./saltdb_v2.js"
)
// const cpu = require("./cpu.js")
const
dotenv
=
require
(
'dotenv'
);
// const express = require("express");
// const salt_stack = require("./database/salt_stack.js")
const
{
Pool
,
Client
}
=
pg
const
{
Pool
,
Client
}
=
pg
dotenv
.
config
()
const
salt
=
new
Salt
({
const
salt
=
new
Salt
({
url
:
"http://54.151.166.113:8000"
,
url
:
process
.
env
.
SALT_URL
,
username
:
"saltuser"
,
username
:
process
.
env
.
SALT_USER
,
password
:
"saltpassword"
,
password
:
process
.
env
.
SALT_PASSWORD
,
eauth
:
"pam"
eauth
:
process
.
env
.
SALT_EAUTH
});
});
const
client
=
new
Client
({
const
client
=
new
Client
({
user
:
'user'
,
user
:
process
.
env
.
POSTGRES_USER
,
password
:
'password'
,
password
:
process
.
env
.
POSTGRES_PASSWORD
,
host
:
'54.151.166.113'
,
host
:
process
.
env
.
POSTGRES_ENDPOINT
,
port
:
'5432'
,
port
:
process
.
env
.
POSTGRES_PORT
,
database
:
'postgres'
,
database
:
process
.
env
.
POSTGRES_DB
,
});
});
const
saltDB
=
new
saltdb_v2
(
salt
,
client
);
const
saltDB
=
new
saltdb_v2
(
salt
,
client
);
// const saltStack = new salt_stack(client)
// const app = express()
// const port = 8505;
client
client
.
connect
()
.
connect
()
...
...
saltdb_v2.js
View file @
d37ae1df
// const request = require('request');
// const request = require('request');
const
dotenv
=
require
(
'dotenv'
);
//
const dotenv = require('dotenv');
const
EventEmitter
=
require
(
'node:events'
);
const
EventEmitter
=
require
(
'node:events'
);
const
salt_stack_v2
=
require
(
'./database/salt_stack_v2.js'
);
const
salt_stack_v2
=
require
(
'./database/salt_stack_v2.js'
);
...
@@ -61,7 +61,7 @@ class saltdb_v2 {
...
@@ -61,7 +61,7 @@ class saltdb_v2 {
try
{
try
{
const
response
=
await
new
Promise
((
resolve
,
reject
)
=>
{
const
response
=
await
new
Promise
((
resolve
,
reject
)
=>
{
this
.
salt_stack
.
update_status_user
(
uuid
,
status
,
time
).
then
(
data
=>
{
this
.
salt_stack
.
update_status_user
(
uuid
,
status
,
time
).
then
(
data
=>
{
console
.
log
(
'update success'
);
//
console.log('update success');
resolve
(
data
);
resolve
(
data
);
}).
catch
(
(
err
)
=>
{
}).
catch
(
(
err
)
=>
{
// console.log('update status user');
// console.log('update status user');
...
@@ -135,7 +135,7 @@ class saltdb_v2 {
...
@@ -135,7 +135,7 @@ class saltdb_v2 {
this
.
salt_stack
.
insert_logs_cpu
(
user_id
,
persent_cpu_used
,
vcpu
,
time
).
then
(
data
=>
{
this
.
salt_stack
.
insert_logs_cpu
(
user_id
,
persent_cpu_used
,
vcpu
,
time
).
then
(
data
=>
{
resolve
(
data
);
resolve
(
data
);
}).
catch
(
(
err
)
=>
{
}).
catch
(
(
err
)
=>
{
console
.
log
(
err
);
//
console.log(err);
reject
(
err
);
reject
(
err
);
})
})
})
})
...
@@ -248,11 +248,11 @@ class saltdb_v2 {
...
@@ -248,11 +248,11 @@ class saltdb_v2 {
var
time
=
data
.
_stamp
.
split
(
'T'
)[
0
]
+
" "
+
data
.
_stamp
.
split
(
'T'
)[
1
].
split
(
'.'
)[
0
]
var
time
=
data
.
_stamp
.
split
(
'T'
)[
0
]
+
" "
+
data
.
_stamp
.
split
(
'T'
)[
1
].
split
(
'.'
)[
0
]
var
user_id
=
data
.
id
var
user_id
=
data
.
id
var
loadavg
=
all
.
loadavg
var
loadavg
=
all
.
loadavg
console
.
log
(
all
);
//
console.log(all);
let
kB
=
9.5367
let
kB
=
9.5367
if
(
cpustats
.
cpu
!=
undefined
)
{
if
(
cpustats
.
cpu
!=
undefined
)
{
var
cpu
=
cpustats
.
cpu
var
cpu
=
cpustats
.
cpu
console
.
log
(
"cpu====>"
,
cpu
);
//
console.log("cpu====>", cpu);
const
idle
=
cpu
.
idle
const
idle
=
cpu
.
idle
const
softirq
=
cpu
.
softirq
const
softirq
=
cpu
.
softirq
const
iowait
=
cpu
.
iowait
const
iowait
=
cpu
.
iowait
...
@@ -272,7 +272,7 @@ class saltdb_v2 {
...
@@ -272,7 +272,7 @@ class saltdb_v2 {
if
(
cpustats
[
e
]
!=
undefined
)
{
if
(
cpustats
[
e
]
!=
undefined
)
{
// console.log(e);
// console.log(e);
const
core
=
e
const
core
=
e
console
.
log
(
core
);
//
console.log(core);
const
value
=
cpustats
[
e
]
const
value
=
cpustats
[
e
]
vcpu
.
push
([
core
,
value
])
vcpu
.
push
([
core
,
value
])
...
@@ -286,20 +286,20 @@ class saltdb_v2 {
...
@@ -286,20 +286,20 @@ class saltdb_v2 {
this
.
update_spec_cpu
(
user_id
,
gb_total_cpu
,
time
)
this
.
update_spec_cpu
(
user_id
,
gb_total_cpu
,
time
)
}
}
if
(
meminfo
.
MemTotal
!=
undefined
)
{
if
(
meminfo
.
MemTotal
!=
undefined
)
{
console
.
log
(
meminfo
);
//
console.log(meminfo);
let
MemTotal
=
parseFloat
(
meminfo
.
MemTotal
.
value
)
let
MemTotal
=
parseFloat
(
meminfo
.
MemTotal
.
value
)
let
MemFree
=
parseFloat
(
meminfo
.
MemFree
.
value
)
let
MemFree
=
parseFloat
(
meminfo
.
MemFree
.
value
)
let
Cached
=
parseFloat
(
meminfo
.
Cached
.
value
)
let
Cached
=
parseFloat
(
meminfo
.
Cached
.
value
)
let
Buffers
=
parseFloat
(
meminfo
.
Buffers
.
value
)
let
Buffers
=
parseFloat
(
meminfo
.
Buffers
.
value
)
let
MemAvailable
=
parseFloat
(
meminfo
.
MemAvailable
.
value
)
let
MemAvailable
=
parseFloat
(
meminfo
.
MemAvailable
.
value
)
console
.
log
(
"MemTotal===>"
,
MemTotal
);
//
console.log("MemTotal===>",MemTotal);
console
.
log
(
"MemAvailable==>"
,
MemAvailable
);
//
console.log("MemAvailable==>",MemAvailable);
let
MemUse
=
MemTotal
-
(
MemFree
+
Cached
+
Buffers
)
let
MemUse
=
MemTotal
-
(
MemFree
+
Cached
+
Buffers
)
let
percent_mem
=
(
MemUse
/
MemTotal
)
*
100
let
percent_mem
=
(
MemUse
/
MemTotal
)
*
100
let
percent_mem_ava
=
(
MemAvailable
/
MemTotal
)
*
100
let
percent_mem_ava
=
(
MemAvailable
/
MemTotal
)
*
100
let
gb_total_mem
=
(
MemTotal
*
kB
)
/
10000000
let
gb_total_mem
=
(
MemTotal
*
kB
)
/
10000000
console
.
log
(
"percent_mem_ava====>"
,
percent_mem_ava
);
//
console.log("percent_mem_ava====>", percent_mem_ava);
console
.
log
(
"percent_mem====>"
,
percent_mem
);
//
console.log("percent_mem====>", percent_mem);
this
.
insert_mem
(
user_id
,
percent_mem
,
Cached
,
Buffers
,
percent_mem_ava
,
time
)
this
.
insert_mem
(
user_id
,
percent_mem
,
Cached
,
Buffers
,
percent_mem_ava
,
time
)
this
.
update_spec_mem
(
user_id
,
gb_total_mem
,
time
)
this
.
update_spec_mem
(
user_id
,
gb_total_mem
,
time
)
...
@@ -309,9 +309,9 @@ class saltdb_v2 {
...
@@ -309,9 +309,9 @@ class saltdb_v2 {
let
one_min
=
load_avg
[
0
][
1
]
let
one_min
=
load_avg
[
0
][
1
]
let
five_min
=
load_avg
[
1
][
1
]
let
five_min
=
load_avg
[
1
][
1
]
let
fifteen_min
=
load_avg
[
2
][
1
]
let
fifteen_min
=
load_avg
[
2
][
1
]
console
.
log
(
one_min
);
//
console.log(one_min);
console
.
log
(
five_min
);
//
console.log(five_min);
console
.
log
(
fifteen_min
);
//
console.log(fifteen_min);
this
.
insert_load
(
user_id
,
one_min
,
five_min
,
fifteen_min
,
time
)
this
.
insert_load
(
user_id
,
one_min
,
five_min
,
fifteen_min
,
time
)
}
}
this
.
check_status_minion
(
user_id
,
time
)
this
.
check_status_minion
(
user_id
,
time
)
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment