Changeset 413 for trunk/Puzzlebox/Synapse/Session.py
- Timestamp:
- 02/07/16 05:41:47 (6 years ago)
- File:
-
- 1 edited
-
trunk/Puzzlebox/Synapse/Session.py (modified) (3 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/Puzzlebox/Synapse/Session.py
r411 r413 7 7 8 8 __changelog__ = """\ 9 Last Update: 201 6.01.269 Last Update: 2014.02.23 10 10 """ 11 11 … … 446 446 447 447 448 # TODO449 print "here"450 export_csv_training = True451 if export_csv_training:452 453 output_file = output_file.replace('.csv', '-trainingEeg.csv')454 455 if self.DEBUG:456 print "Writing file:",457 print output_file458 459 outputData = self.exportTrainingDataToCSV(parent=parent, source=source, target=target)460 461 if outputData != None:462 463 file = open(str(output_file), 'w')464 file.write(outputData)465 file.close()466 467 468 448 ################################################################## 469 449 … … 724 704 return(output) 725 705 726 727 ##################################################################728 729 def exportTrainingDataToCSV(self, parent=None, source=None, target=None):730 731 # handle importing class from multiple sources732 if parent == None:733 if self.parent == None:734 parent = self735 else:736 parent = self.parent737 738 if source == None:739 if self.parent == None:740 source = self741 else:742 source = self.parent743 744 if target == None:745 if self.parent == None:746 target = self747 else:748 target = self.parent749 750 751 try:752 truncate_csv_timezone = target.configuration.EXPORT_CSV_TRUNCATE_TIMEZONE753 except:754 truncate_csv_timezone = False755 756 757 if source.packets['rawEeg'] == []:758 if self.DEBUG:759 print "WARNING: No raw EEG packets"760 return(None)761 else:762 if self.DEBUG:763 print "INFO: Raw EEG packets:",764 print len(source.packets['rawEeg'])765 766 767 #headers = 'Date,Time,Raw EEG'768 #headers = headers + '\n'769 770 771 headers = 'Date,Time'772 773 774 customDataHeaders = []775 for header in parent.customDataHeaders:776 customDataHeaders.append(header)777 for plugin in parent.activePlugins:778 #print plugin.name779 for header in plugin.customDataHeaders:780 customDataHeaders.append(header)781 782 for each in customDataHeaders:783 headers = headers + ',%s' % each784 785 786 headers = headers +',%s' % 'Raw EEG'787 788 789 headers = headers + '\n'790 791 792 csv = {}793 794 for packet in source.packets['rawEeg']:795 796 # NOTE: Move this to ThinkGear Server object797 if 'rawEeg' in packet.keys():798 799 if packet['timestamp'] not in csv.keys():800 801 802 timestamp = packet['timestamp']803 804 (date, localtime) = source.parseTimeStamp(timestamp, \805 truncate_time_zone=truncate_csv_timezone)806 807 csv[timestamp] = {}808 csv[timestamp]['Date'] = date809 csv[timestamp]['Time'] = localtime810 csv[timestamp]['rawEeg'] = packet['rawEeg']811 812 813 csv[timestamp].update(self.collectProcessedData(parent, source, timestamp))814 815 816 output = headers817 818 timestamps = csv.keys()819 820 # Don't sort timestamps in order to better preserve the original raw signal821 #timestamps.sort()822 823 for timestamp in timestamps:824 825 row = '%s,%s,%s' % \826 (csv[timestamp]['Date'], \827 csv[timestamp]['Time'], \828 csv[timestamp]['rawEeg'])829 830 831 832 for header in customDataHeaders:833 if header in csv[timestamp].keys():834 row = row + ',%s' % csv[timestamp][header]835 else:836 #row = row + ','837 row = ''838 if self.DEBUG > 1:839 print "WARN: empty signals packet:",840 print csv[timestamp]841 break842 843 844 845 846 row = row + '\n'847 848 output = output + row849 850 851 return(output)852 853 854 #################################################################855 856 def collectProcessedData(self, parent, source, match_timestamp):857 858 # Return processed and custom data fields for this timestamp859 860 861 if self.DEBUG:862 print "Match Timestamp:",863 print match_timestamp864 865 866 packet_timestamps = []867 for packet in source.packets['signals']:868 869 if 'blinkStrength' in packet.keys():870 # Skip any blink packets from log871 continue872 873 packet_timestamps.append(packet['timestamp'])874 875 876 packet_timestamps.sort()877 878 879 #found = {}880 881 for timestamp in packet_timestamps:882 883 if self.DEBUG:884 print "--> Search Timestamp:",885 print match_timestamp886 887 #if (found == {}):888 #found = packet889 #continue890 891 # Keep searching until892 if (match_timestamp > timestamp):893 continue894 895 #found = packet896 897 if self.DEBUG:898 print "Matched Timestamp:",899 print timestamp900 901 902 packet = {}903 904 for each in source.packets['signals']:905 if each['timestamp'] == timestamp:906 #if self.DEBUG:907 #print "INFO: Packet Found:",908 #print each909 packet = each910 911 912 data = {}913 914 for plugin in parent.activePlugins:915 if plugin.customDataHeaders != []:916 if self.DEBUG > 2:917 print "INFO: [Synapse:Session] Exporting:",918 print plugin.name919 try:920 data = plugin.processPacketForExport(packet=packet, output=data)921 if self.DEBUG > 2:922 print "INFO [Synapse:Session]: Export Successful"923 print plugin.name924 except Exception, e:925 if self.DEBUG:926 print "ERROR: [Synapse:Session] Exception calling processPacketForExport on",927 print plugin.name928 929 930 #print "INFO: data",931 #print data932 933 return data934 935 936 #for header in customDataHeaders:937 938 #if 'custom' in packet.keys() and \939 #header in packet['custom'].keys():940 941 #timestamp = packet['timestamp']942 #(date, localtime) = source.parseTimeStamp(timestamp, \943 #truncate_time_zone=truncate_csv_timezone)944 945 #if timestamp not in csv.keys():946 #data = {}947 #data['Date'] = date948 #data['Time'] = localtime949 #if self.DEBUG:950 #print "WARN: Unmatched custom packet:",951 #print packet952 953 #data[header] = packet['custom'][header]954 955 956 957 958 #for packet in source.packets['signals']:959 960 961 ## NOTE: Move this to ThinkGear Server object962 ##if 'rawEeg' in packet.keys():963 ##continue964 965 966 #if 'timestamp' not in packet.keys() and len(packet.keys()) == 1:967 #if self.DEBUG:968 #print "WARN: Skipping empty packet:",969 #print packet970 ## skip empty packets971 #continue972 973 974 #print "packet:",975 #print packet976 977 #timestamp = packet['timestamp']978 ##(date, localtime) = self.parseTimeStamp(timestamp, \979 ##truncate_time_zone=truncate_csv_timezone)980 #(date, localtime) = source.parseTimeStamp(timestamp, \981 #truncate_time_zone=truncate_csv_timezone)982 983 #if timestamp not in csv.keys():984 985 986 987 988 ##timestamp = packet['timestamp']989 ###(date, localtime) = self.parseTimeStamp(timestamp, \990 ###truncate_time_zone=truncate_csv_timezone)991 ##(date, localtime) = source.parseTimeStamp(timestamp, \992 ##truncate_time_zone=truncate_csv_timezone)993 994 #csv[timestamp] = {}995 #csv[timestamp]['Date'] = date996 #csv[timestamp]['Time'] = localtime997 998 999 #for plugin in parent.activePlugins:1000 #if plugin.customDataHeaders != []:1001 #if self.DEBUG > 2:1002 #print "INFO: [Synapse:Session] Exporting:",1003 #print plugin.name1004 #try:1005 #csv[timestamp] = plugin.processPacketForExport(packet=packet, output=csv[timestamp])1006 #if self.DEBUG > 2:1007 #print "INFO [Synapse:Session]: Export Successful"1008 #print plugin.name1009 #except Exception, e:1010 #if self.DEBUG:1011 #print "ERROR: [Synapse:Session] Exception calling processPacketForExport on",1012 #print plugin.name1013 1014 1015 #for header in customDataHeaders:1016 1017 #if 'custom' in packet.keys() and \1018 #header in packet['custom'].keys():1019 1020 #timestamp = packet['timestamp']1021 #(date, localtime) = source.parseTimeStamp(timestamp, \1022 #truncate_time_zone=truncate_csv_timezone)1023 1024 #if timestamp not in csv.keys():1025 #csv[timestamp] = {}1026 #csv[timestamp]['Date'] = date1027 #csv[timestamp]['Time'] = localtime1028 #if self.DEBUG:1029 #print "WARN: Unmatched custom packet:",1030 #print packet1031 1032 #csv[timestamp][header] = packet['custom'][header]1033 1034 706 1035 707 #################################################################
Note: See TracChangeset
for help on using the changeset viewer.
