realtime_web Files · plotter/consumers.py

New version with cards and status alerts

Developer - - Load All Authors

File last commit:

r11:2395d68d2d5f


                r11:2395d68d2d5f

Download file

             consumers.py
        
                    56 lines
            
             | 2.2 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / plotter / consumers.py
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        Developer
    
New version with cards and status alerts

              r11
            
      #!/usr/bin/python

      # -*- coding: UTF-8 -*-

        Juan C. Espinoza
    
Docker working

              r1
            
      import os

        jespinoza
    
First version RTI, Spectra, Noise + Docker

              r0
            
      import json

        jespinoza
    
Reorganize models, smaller docker, others

              r2
            
        jespinoza
    
First version RTI, Spectra, Noise + Docker

              r0
            
      from datetime import datetime

        Juan C. Espinoza
    
Docker working

              r1
            
        jespinoza
    
First version RTI, Spectra, Noise + Docker

              r0
            
      from pymongo import MongoClient

      from channels.handler import AsgiHandler

      from channels.auth import channel_session_user

      from channels import Group

        Developer
    
New version with cards and status alerts

              r11
            
      # Here we create the db named "dbplots"

        Juan C. Espinoza
    
Docker working

              r1
            
      host = os.environ.get('HOST_MONGO', 'localhost')

      CLIENT = MongoClient('{}:27017'.format(host))

        jespinoza
    
First version RTI, Spectra, Noise + Docker

              r0
            
      DB = CLIENT['dbplots']

      # Connected to websocket.connect

        Developer
    
New version with cards and status alerts

              r11
            
      def ws_connect(message, code=None, plot=None):

        jespinoza
    
First version RTI, Spectra, Noise + Docker

              r0
            
          message.reply_channel.send({'accept': True})

        Developer
    
New version with cards and status alerts

              r11
            
          if plot == 'main':

              Group('main').add(message.reply_channel)

              print('New main connection')

          else:

              pk = message.content['query_string'].decode().split('=')[1]

              Group('{}_{}'.format(pk, plot)).add(message.reply_channel)

              print('New connection from: {}, Group: {}_{}'.format(message.content['client'][0], pk, plot))

        jespinoza
    
First version RTI, Spectra, Noise + Docker

              r0
            
      def ws_message(message, code, plot):

          # Accept the incoming connection

          dt = datetime.strptime(str(json.loads(message.content['text'])['date']), '%d/%m/%Y')

        jespinoza
    
Reorganize models, smaller docker, others

              r2
            
          exp = DB.exp_meta.find_one({'code': int(code), 'date': dt})

        jespinoza
    
Fix server for noise data, correct codes

              r3
            
          if exp and plot in exp['plots']:

        jespinoza
    
First version RTI, Spectra, Noise + Docker

              r0
            
              if plot == 'spc':

        jespinoza
    
Reorganize models, smaller docker, others

              r2
            
                  datas = DB.exp_data.find({'expmeta': exp['_id']}, ['time', 'data']).sort('time', -1).limit(1)[0]

                  exp['time'] = [datas['time']]

                  exp['spc'] = datas['data']['spc']

                  exp['rti'] = datas['data']['rti']

                  exp['noise'] = datas['data']['noise']

        jespinoza
    
First version RTI, Spectra, Noise + Docker

              r0
            
              else:

        jespinoza
    
Reorganize models, smaller docker, others

              r2
            
                  datas = DB.exp_data.find({'expmeta': exp['_id']}, ['time', 'data']).sort('time', 1)

        jespinoza
    
First version RTI, Spectra, Noise + Docker

              r0
            
                  dum = [(d['time'], d['data'][plot]) for d in datas]

        jespinoza
    
Reorganize models, smaller docker, others

              r2
            
                  exp['time'] = [d[0] for d in dum]

        Juan C. Espinoza
    
Docker working

              r1
            
                  dum = [d[1] for d in dum]

        Developer
    
New version with cards and status alerts

              r11
            
                  exp[plot] = [t for t in map(list, zip(*dum))]

              print([datetime.fromtimestamp(t) for t in exp['time']])

        jespinoza
    
Reorganize models, smaller docker, others

              r2
            
              exp.pop('date', None)

              exp.pop('_id', None)

              message.reply_channel.send({'text': json.dumps(exp)})

        jespinoza
    
First version RTI, Spectra, Noise + Docker

              r0
            
          else:

              message.reply_channel.send({'text': json.dumps({'interval': 0})})

      # Connected to websocket.disconnect

      def ws_disconnect(message, code, plot):

          Group('{}_{}'.format(code, plot)).discard(message.reply_channel)

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

Developer New version with cards and status alerts	r11	#!/usr/bin/python
		# -- coding: UTF-8 --
Juan C. Espinoza Docker working	r1	import os
jespinoza First version RTI, Spectra, Noise + Docker	r0	import json
jespinoza Reorganize models, smaller docker, others	r2
jespinoza First version RTI, Spectra, Noise + Docker	r0	from datetime import datetime
Juan C. Espinoza Docker working	r1
jespinoza First version RTI, Spectra, Noise + Docker	r0	from pymongo import MongoClient

		from channels.handler import AsgiHandler
		from channels.auth import channel_session_user
		from channels import Group
Developer New version with cards and status alerts	r11	# Here we create the db named "dbplots"
Juan C. Espinoza Docker working	r1	host = os.environ.get('HOST_MONGO', 'localhost')
		CLIENT = MongoClient('{}:27017'.format(host))
jespinoza First version RTI, Spectra, Noise + Docker	r0	DB = CLIENT['dbplots']

		# Connected to websocket.connect
Developer New version with cards and status alerts	r11	def ws_connect(message, code=None, plot=None):
jespinoza First version RTI, Spectra, Noise + Docker	r0	message.reply_channel.send({'accept': True})
Developer New version with cards and status alerts	r11	if plot == 'main':
		Group('main').add(message.reply_channel)
		print('New main connection')
		else:
		pk = message.content['query_string'].decode().split('=')[1]
		Group('{}_{}'.format(pk, plot)).add(message.reply_channel)
		print('New connection from: {}, Group: {}_{}'.format(message.content['client'][0], pk, plot))
jespinoza First version RTI, Spectra, Noise + Docker	r0
		def ws_message(message, code, plot):
		# Accept the incoming connection
		dt = datetime.strptime(str(json.loads(message.content['text'])['date']), '%d/%m/%Y')
jespinoza Reorganize models, smaller docker, others	r2	exp = DB.exp_meta.find_one({'code': int(code), 'date': dt})
jespinoza Fix server for noise data, correct codes	r3
		if exp and plot in exp['plots']:
jespinoza First version RTI, Spectra, Noise + Docker	r0	if plot == 'spc':
jespinoza Reorganize models, smaller docker, others	r2	datas = DB.exp_data.find({'expmeta': exp['_id']}, ['time', 'data']).sort('time', -1).limit(1)[0]
		exp['time'] = [datas['time']]
		exp['spc'] = datas['data']['spc']
		exp['rti'] = datas['data']['rti']
		exp['noise'] = datas['data']['noise']
jespinoza First version RTI, Spectra, Noise + Docker	r0	else:
jespinoza Reorganize models, smaller docker, others	r2	datas = DB.exp_data.find({'expmeta': exp['_id']}, ['time', 'data']).sort('time', 1)
jespinoza First version RTI, Spectra, Noise + Docker	r0	dum = [(d['time'], d['data'][plot]) for d in datas]
jespinoza Reorganize models, smaller docker, others	r2	exp['time'] = [d[0] for d in dum]
Juan C. Espinoza Docker working	r1	dum = [d[1] for d in dum]
Developer New version with cards and status alerts	r11	exp[plot] = [t for t in map(list, zip(*dum))]
		print([datetime.fromtimestamp(t) for t in exp['time']])
jespinoza Reorganize models, smaller docker, others	r2	exp.pop('date', None)
		exp.pop('_id', None)
		message.reply_channel.send({'text': json.dumps(exp)})
jespinoza First version RTI, Spectra, Noise + Docker	r0	else:
		message.reply_channel.send({'text': json.dumps({'interval': 0})})

		# Connected to websocket.disconnect
		def ws_disconnect(message, code, plot):
		Group('{}_{}'.format(code, plot)).discard(message.reply_channel)