FilesExpand file tree

main

/

send.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

82 lines (64 loc) · 1.78 KB

main

/

send.py

Copy path

Top

File metadata and controls

• Code
• Blame

82 lines (64 loc) · 1.78 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

import json

import os

import datetime

import time

import requests

import hashlib

from requests_futures.sessions import FuturesSession

print()

print(os.environ)

print()

def get_now():

return round(time.time() * 1000)

send_url = os.getenv("SEND_URL")

if send_url == "":

send_url = None

sign_key = os.getenv("SIGN_KEY")

if sign_key == "":

sign_key = None

init_time = get_now()

session = FuturesSession()

last_time = init_time

with open("/proc/self/mountinfo") as file:

line = file.readline().strip()

while line:

if "/docker/containers/" in line:

container_id = line.split("/docker/containers/")[

-1

] # Take only text to the right

container_id = container_id.split("/")[0] # Take only text to the left

break

line = file.readline().strip()

def send(type: str, status: str, payload: dict = {}, init=False):

global id

global dest

global init_time

global last_time

now = get_now()

if init:

init_time = now

data = {

"type": type,

"status": status,

"container_id": container_id,

"time": now,

"t": now - init_time,

"tsl": now - last_time,

"payload": payload,

}

last_time = now

if init:

data["init"] = True

if send_url:

input = json.dumps(data, separators=(",", ":")) + sign_key

sig = hashlib.md5(input.encode("utf-8")).hexdigest()

data["sig"] = sig

print(datetime.datetime.now(), data)

if send_url:

session.post(send_url, json=data)

# try:

# requests.post(send_url, json=data) # , timeout=0.0000000001)

# except requests.exceptions.ReadTimeout:

# except requests.exceptions.RequestException as error:

# print(error)

# pass