FilesExpand file tree

 master

/

example_graphql.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

executable file

·

78 lines (62 loc) · 2.27 KB

 master

/

example_graphql.py

Copy path

Top

File metadata and controls

• Code
• Blame

executable file

·

78 lines (62 loc) · 2.27 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

#!/usr/bin/env python

"""Cloudflare API code - example"""

import os

import sys

import time

import datetime

import pytz

sys.path.insert(0, os.path.abspath('..'))

import CloudFlare

def now_iso8601_time(h_delta):

"""Cloudflare API code - example"""

t = time.time() - (h_delta * 3600)

r = datetime.datetime.fromtimestamp(int(t), tz=pytz.timezone("UTC")).strftime('%Y-%m-%dT%H:%M:%SZ')

return r

def main():

"""Cloudflare API code - example"""

# Grab the zone name

try:

zone_name = sys.argv[1]

params = {'name':zone_name, 'per_page':1}

except IndexError:

exit('usage: example_graphql zone')

cf = CloudFlare.CloudFlare()

# grab the zone identifier

try:

zones = cf.zones.get(params=params)

except CloudFlare.exceptions.CloudFlareAPIError as e:

exit('/zones.get %d %s - api call failed' % (e, e))

except Exception as e:

exit('/zones - %s - api call failed' % (e))

date_before = now_iso8601_time(0) # now

date_after = now_iso8601_time(7 * 24) # 7 days worth

zone_id = zones[0]['id']

query="""

query {

viewer {

zones(filter: {zoneTag: "%s"} ) {

httpRequests1dGroups(limit:40, filter:{date_lt: "%s", date_gt: "%s"}) {

sum { countryMap { bytes, requests, clientCountryName } }

dimensions { date }

}

}

}

}

""" % (zone_id, date_before[0:10], date_after[0:10]) # only use yyyy-mm-dd part for httpRequests1dGroups

# query - always a post

try:

r = cf.graphql.post(data={'query':query})

except CloudFlare.exceptions.CloudFlareAPIError as e:

exit('/graphql.post %d %s - api call failed' % (e, e))

## only one zone, so use zero'th element!

zone_info = r['data']['viewer']['zones'][0]

httpRequests1dGroups = zone_info['httpRequests1dGroups']

for h in sorted(httpRequests1dGroups, key=lambda v: v['dimensions']['date']):

result_date = h['dimensions']['date']

result_info = h['sum']['countryMap']

print(result_date)

for element in sorted(result_info, key=lambda v: -v['bytes']):

print(" %7d %7d %2s" % (element['bytes'], element['requests'], element['clientCountryName']))

if __name__ == '__main__':

main()

exit(0)