Skip to content

Instantly share code, notes, and snippets.

View srijiths's full-sized avatar

Srijith.S srijiths

View GitHub Profile
@srijiths
srijiths / nano_time.txt
Created September 24, 2019 04:53
People counter nano time stats.
time taken for turbo decode : 38
time taken for yolo processing : 33080
time taken for image patches extraction : 733
time taken for deep sort : 1771
time taken for MTCNN : 2074
time taken for GA model : 826
time taken for MTCNN : 162
time taken for MTCNN : 279
time taken for GA model : 256
Sending build context to Docker daemon 2.131MB
Step 1/31 : FROM nvidia/cuda:10.0-cudnn7-devel-ubuntu16.04 AS builder
---> e1d637677e0d
Step 2/31 : ENV DEPS "build-essential git ca-certificates curl unzip wget"
---> Running in 2d76e019ece9
Removing intermediate container 2d76e019ece9
---> 1c8821a2be7f
Step 3/31 : ENV NVIDIA_VISIBLE_DEVICES all
---> Running in d25c2cae5208
Removing intermediate container d25c2cae5208
<Hash "binary_label_14beaf75f55b7893fa60f79e3cece9725be35de9_1559114665833122_1559114665833182": {'encoding': '\x04\xf3g;q\xe5>=\xf8@\xdb\xbaj\xa9q\xbc\x11\xf2c\xbc\xe2\x86\x81\xbc~R\xbb\xbde\x85\x1d\xbdG\xb2\xb1<\xdda!<\xb2R\xef\xbcm|\xa0;\x02\xda_\xbc\xedl =\xee_\x0c<\x86L\xcd;\x92\xea\xae\xbc\xfa/E\xbd\xf4\x8fF=\xe2\xfe\xcf=~-\xc8\xbc\x1f\x0c=\xbcu;\x1b\xbd\xa0$_=z\xb4\x8a<@p\xa8\xbd4\xba\x03=\xf4\xe7\xa3\xbd\x1c\\,=\xf8\xab\xfb\xbb\xc7-&=\xad\x0e\x90\xbd\xb6qB=\xe9\xa7\x8c\xbc\x1dq\xbb\xbd\xbeQ\x9b\xbc\x9c1\x18=,\xa1\x83\xbc\xc4\xe7\x98\xbd\xf1V\xde\xbc\xb0\xb5K\xbdI\xd1m\xbdG9\r\xbdrH\x9e<:,5\xbd\x9fP?<\xf6m\xa0\xbdWP\xa4\xbbzj\x94\xbd\x19)\x96=\xd1p\xd4\xbc\xe9\x0cd=u\xb6\x12\xbaG\x8d3\xbd\xc0\x1d\n>\xb8`\xeb\xbc 0\xf7;%\x12\xc2\xbd\x8dV\xbb\xbc\xe84\x11<m\x07X=\xb2\xaa*=\x06\xbed\xbd\x01\x07\xc8\xbb\x0c\x072\xbc\x84\xde\xdf<%\x8fA\xbc8\x00\x1e\xbd \xe0Y\xbd\xecd\xcb=Kt\x8e\xbc\x16\xfa\xdc\xbb\x82\x07\x06=\xd1\xbcD=\x9e+\r=\x14\xc0\x17=X.\x12\xbdj\xf8\xa2\xbd)0\x11=\xce\xd9\xa2\xbd2B#=\xda\x8cB<\'\xb3\x
import redisai as rai
from PIL import Image
import numpy as np
import cv2
from datetime import datetime
def letter_box(numpy_image, height):
shape = numpy_image.shape[:2]
ratio = float(height) / max(shape)
new_shape = (int(round(shape[1] * ratio)), int(round(shape[0] * ratio)))
##
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import org.apache.avro.Schema;
import org.apache.avro.generic.GenericData;
import org.apache.kafka.connect.data.SchemaAndValue;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
[2016-08-06 15:00:17,968] INFO Successfully joined group connect-elasticsearch-sink with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:434)
[2016-08-06 15:00:17,968] INFO Setting newly assigned partitions [sensor-output-4, sensor-output-3, sensor-output-2, sensor-output-1, sensor-output-0] for group connect-elasticsearch-sink (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:219)
[2016-08-06 15:00:19,505] WARN Failed to execute bulk request java.util.ConcurrentModificationException. (io.confluent.connect.elasticsearch.internals.BulkProcessor:159)
[2016-08-06 15:00:19,518] WARN Failed to execute bulk request java.util.ConcurrentModificationException. (io.confluent.connect.elasticsearch.internals.BulkProcessor:159)
[2016-08-06 15:00:20,205] WARN Failed to execute bulk request java.util.ConcurrentModificationException. (io.confluent.connect.elasticsearch.internals.BulkProcessor:159)
Exception in thread "I/O dispatcher 8" [2016-08-06 15:00:33,651] ERROR Unexpected ex
NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{172.30.1.168}{172.30.1.168:9300}]]
at org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:290)
at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:207)
at org.elasticsearch.client.transport.support.TransportProxyClient.execute(TransportProxyClient.java:55)
at org.elasticsearch.client.transport.TransportClient.doExecute(TransportClient.java:288)
at org.elasticsearch.client.support.AbstractClient.execute(AbstractClient.java:359)
at org.elasticsearch.client.support.AbstractClient.bulk(AbstractClient.java:436)
at org.elasticsearch.action.bulk.Retry$AbstractRetryHandler.execute(Retry.java:219)
at org.elasticsearch.action.bulk.Retry.withAsyncBackoff(Retry.java:72)
at org.elasticsearch.action.bulk.BulkRequestHandler$AsyncBulkRequestHandler.
org.apache.kafka.connect.errors.ConnectException: Flush failed with non retriable exception.
at io.confluent.connect.elasticsearch.ElasticsearchWriter.flush(ElasticsearchWriter.java:319)
at io.confluent.connect.elasticsearch.ElasticsearchSinkTask.flush(ElasticsearchSinkTask.java:137)
at org.apache.kafka.connect.runtime.WorkerSinkTask.commitOffsets(WorkerSinkTask.java:275)
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:155)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:142)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)