python - Python 中的光线执行
问题描述
我已安装 Ray 以提高 Intel® Celeron(R) CPU N3060 @ 1.60GHz × 2 中 Caffe 对象检测代码的性能。我遇到以下错误：
ioz@ioz-HP-Laptop-15-bs0xx:~/2019_07_13/CodeWrks$ python vel2.py
2019-08-31 18:56:48,743 WARNING worker.py:1373 -- WARNING: Not updating worker name since `setproctitle` is not installed. Install this with `pip install setproctitle` (or ray[debug]) to enable monitoring of worker processes.
2019-08-31 18:56:48,744 INFO node.py:498 -- Process STDOUT and STDERR is being redirected to /tmp/ray/session_2019-08-31_18-56-48_744086_5437/logs.
2019-08-31 18:56:48,874 INFO services.py:409 -- Waiting for redis server at 127.0.0.1:16018 to respond...
2019-08-31 18:56:49,011 INFO services.py:409 -- Waiting for redis server at 127.0.0.1:45059 to respond...
2019-08-31 18:56:49,029 INFO services.py:809 -- Starting Redis shard with 0.81 GB max memory.
2019-08-31 18:56:49,080 INFO node.py:512 -- Process STDOUT and STDERR is being redirected to /tmp/ray/session_2019-08-31_18-56-48_744086_5437/logs.
2019-08-31 18:56:49,082 WARNING services.py:1330 -- WARNING: The default object store size of 1.21 GB will use more than 50% of the available memory on this node (1.66 GB). Consider setting the object store memory manually to a smaller size to avoid memory contention with other applications.
2019-08-31 18:56:49,084 INFO services.py:1475 -- Starting the Plasma object store with 1.21 GB memory using /dev/shm.
Exception in thread Thread-8 (most likely raised during interpreter shutdown):
Traceback (most recent call last):
File "/usr/lib/python2.7/threading.py", line 801, in __bootstrap_inner
File "/usr/lib/python2.7/threading.py", line 1071, in run
File "/usr/lib/python2.7/threading.py", line 614, in wait
File "/usr/lib/python2.7/threading.py", line 364, in wait
<type 'exceptions.ValueError'>: list.remove(x): x not in list
Exception in thread Thread-7 (most likely raised during interpreter shutdown):
ioz@ioz-HP-Laptop-15-bs0xx:~/2019_07_13/CodeWrks$ python vel2.py
2019-08-31 18:56:54,792 WARNING worker.py:1373 -- WARNING: Not updating worker name since `setproctitle` is not installed. Install this with `pip install setproctitle` (or ray[debug]) to enable monitoring of worker processes.
2019-08-31 18:56:54,793 INFO node.py:498 -- Process STDOUT and STDERR is being redirected to /tmp/ray/session_2019-08-31_18-56-54_792936_5491/logs.
2019-08-31 18:56:54,920 INFO services.py:409 -- Waiting for redis server at 127.0.0.1:41843 to respond...
2019-08-31 18:56:55,074 INFO services.py:409 -- Waiting for redis server at 127.0.0.1:28148 to respond...
2019-08-31 18:56:55,083 INFO services.py:809 -- Starting Redis shard with 0.81 GB max memory.
2019-08-31 18:56:55,136 INFO node.py:512 -- Process STDOUT and STDERR is being redirected to /tmp/ray/session_2019-08-31_18-56-54_792936_5491/logs.
2019-08-31 18:56:55,138 WARNING services.py:1330 -- WARNING: The default object store size of 1.21 GB will use more than 50% of the available memory on this node (1.65 GB). Consider setting the object store memory manually to a smaller size to avoid memory contention with other applications.
2019-08-31 18:56:55,139 INFO services.py:1475 -- Starting the Plasma object store with 1.21 GB memory using /dev/shm.
我没有尝试过任何东西，因为我得到了两个不同的输出。请找到代码片段
import numpy as np
from imutils.video import WebcamVideoStream
from imutils.video import FPS
import argparse
import imutils
# import schedule
import sys
import datetime
import argparse
import logging
import os
import requests
import sched
import requests_cache
import time
from datetime import date
from datetime import timedelta
from imutils import contours
from skimage import measure
from threading import Thread
import json
import ray
ray.init() // Ray
initialized
requests_cache.install_cache('api_cache', backend='memory', expire_after=180)
try:
import cv2 as cv
except ImportError:
raise ImportError('Can\'t find OpenCV Python module. If you\'ve built it from sources without installation, '
'configure environemnt variable PYTHONPATH to "opencv_build_dir/lib" directory (with "python3" subdirectory if required)')
@ray.remote
def Zoom(cv2Object, zoomSize):
# Resizes the image/video frame to the specified amount of "zoomSize".
# A zoomSize of "2", for example, will double the canvas size
cv2Object = imutils.resize(cv2Object, width=(zoomSize * cv2Object.shape[1]))
# center is simply half of the height & width (y/2,x/2)
center = (cv2Object.shape[0] / 2, cv2Object.shape[1] / 2)
# cropScale represents the top left corner of the cropped frame (y/x)
cropScale = (center[0] / zoomSize, center[1] / zoomSize)
# The image/video frame is cropped to the center with a size of the original picture
# image[y1:y2,x1:x2] is used to iterate and grab a portion of an image
# (y1,x1) is the top left corner and (y2,x1) is the bottom right corner of new cropped frame.
# cv2Object = cv2Object[cropScale[0]:(center[0] + cropScale[0]), cropScale[1]:(center[1] + cropScale[1])]
return cv2Object
@ray.remote
def sr():
try:
smsCount = 0
inWidth = 600
inHeight = 600
WHRatio = inWidth / float(inHeight)
inScaleFactor = 0.007843
meanVal = 127.5
firstFrame = None
classNames = ('background',
'aeroplane', 'bicycle', 'bird', 'boat',
'bottle', 'bus', 'car', 'cat', 'chair',
'cow', 'diningtable', 'dog', 'horse',
'motorbike', 'person', 'pottedplant',
'sheep', 'sofa', 'train', 'tvmonitor')
parser = argparse.ArgumentParser()
parser.add_argument("--video", help="path to video file. If empty, camera's stream will be used")
parser.add_argument("--prototxt", default="MobileNetSSD_deploy.prototxt",
help="path to caffe prototxt")
parser.add_argument("-m", "--caffemodel", default="MobileNetSSD_deploy.caffemodel",
help="path to caffemodel file, download it here: "
"https://github.com/chuanqi305/MobileNet-SSD/")
parser.add_argument("--thr", default=0.5, help="confidence threshold to filter out weak detections")
args = parser.parse_args()
today = datetime.date.today()
todayerr = today.isoformat()
logging.basicConfig(level=logging.DEBUG, filename='exceptions_Cam01_' + str(todayerr) + '.txt')
num = 0
# fvs = VideoStream("rtsp://admin:Admin@123@192.168.1.14:554/cam/realmonitor?channel=7&subtype=0").start()
# fvs = VideoStream("rtsp://admin:admin12345@192.168.1.195:554/unicat/c3/s1/live").start()
saliency = None
with open('URL.txt', 'r') as fobj:
data = json.load(fobj)
r = requests.get(data['ClientUrl'])
res = json.loads(r.text)
fgbg = cv.bgsegm.createBackgroundSubtractorMOG()
for obj in res:
if obj.get('camera_id') == str(data['cam_id']):
print(obj.get('camera_url'))
fvs = WebcamVideoStream(0).start()
time.sleep(2.0)