Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Feat: Add functionality to calculate intra-cluster distances and compare them between original and fine-tuned models #49

Merged
merged 18 commits into from
Aug 2, 2024
Merged

Feat: Add functionality to calculate intra-cluster distances and compare them between original and fine-tuned models #49

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
18 commits
Select commit Hold shift + click to select a range
8631b6f
feat: Add functionality to calculate intra-cluster distances and comp…
Devasy23 Jul 14, 2024
b5c55c0
Created using Colab
Devasy23 Jul 14, 2024
1e4ac9c
Updated code to load finetuned model
devansh-shah-11 Jul 15, 2024
bcffd5d
made fixing changes
Devasy23 Jul 16, 2024
20096e8
feat: Add functionality to calculate intra-cluster distances and comp…
Devasy23 Jul 16, 2024
1010427
updated gitignore
devansh-shah-11 Jul 17, 2024
51225f2
Updated code to load finetuned model
devansh-shah-11 Jul 19, 2024
0b452e9
Now everything works
Devasy23 Jul 20, 2024
856476e
Created using Colab
Devasy23 Jul 20, 2024
70f67b6
Kaggle Notebook | face rec_trail on indian faces | Version 2
Devasy23 Jul 23, 2024
0971d16
Added finetuned model
devansh-shah-11 Jul 25, 2024
bc89ae8
Updated endpoints to calculate embeddings via finetuned model
devansh-shah-11 Jul 25, 2024
8afe690
Added code to extract face, working Recognize_Face endpoint
devansh-shah-11 Jul 25, 2024
19a57cd
updated embedding function
devansh-shah-11 Jul 28, 2024
1b7c685
Merge branch 'main' of https://github.com/devansh-shah-11/FaceRec int…
Devasy23 Jul 29, 2024
02bd51e
updated code to recalculate embeddings
devansh-shah-11 Jul 30, 2024
0a207e1
Updated vector search and recognize face endpoint
devansh-shah-11 Jul 30, 2024
d3a2916
removed "mtcnn" from detector backend to check embedding accuracy
devansh-shah-11 Jul 30, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions .gitignore
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -143,3 +143,4 @@ __pyc
FaceRec/static/Images/uploads/*
Images/dbImages/*
Images/Faces/*
Images/
Comment on lines 143 to +146
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CODE REVIEW

The changes seem to involve moving directories and adding an entire directory. It would be beneficial to provide more context and explanation behind these changes to ensure they are necessary. Consider breaking up these changes into smaller, more meaningful commits for better clarity and version control.

Consider providing more descriptive commit messages for clarity

2 changes: 1 addition & 1 deletion API/database.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ def vector_search(self, collection, embedding):
{
'$vectorSearch': {
'index': 'vector_index',
'path': 'face_embedding',
'path': 'embedding',
'queryVector': embedding,
'numCandidates': 20,
'limit': 20,
Expand Down
175 changes: 134 additions & 41 deletions API/route.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
from datetime import datetime
from io import BytesIO
from typing import List

from tensorflow.keras.models import load_model
from bson import ObjectId
from deepface import DeepFace
from dotenv import load_dotenv
Comment on lines 8 to 14
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CODE REVIEW

Import statements should be grouped in the following order:

  1. Standard library imports
  2. Related third party imports
  3. Local application/library specific imports
from datetime import datetime
from io import BytesIO
from typing import List
from bson import ObjectId

from dotenv import load_dotenv
from tensorflow.keras.models import load_model
from deepface import DeepFace

Expand All @@ -20,6 +20,8 @@
from matplotlib import pyplot as plt
from PIL import Image
from pydantic import BaseModel
import numpy as np
from keras.preprocessing import image

from API.database import Database
from API.utils import init_logging_config
Comment on lines 20 to 27
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CODE REVIEW

Consider organizing imports alphabetically for easier readability. It's also recommended to group standard library imports, third-party imports, and local imports separately.

from PIL import Image
import numpy as np
from keras.preprocessing import image
from matplotlib import pyplot as plt
from pydantic import BaseModel

from API.database import Database
from API.utils import init_logging_config

Expand All @@ -36,7 +38,7 @@

collection = 'faceEntries'
collection2 = 'ImageDB'

collection3 = 'VectorDB'

# Models for the data to be sent and received by the server
class Employee(BaseModel):
Expand All @@ -53,6 +55,84 @@
Department: str
Images: list[str]

def load_and_preprocess_image(img_path, target_size=(160, 160)):

img = image.load_img(img_path, target_size=target_size)
img_array = image.img_to_array(img)
img_array = np.expand_dims(img_array, axis=0)
img_array /= 255.0
return img_array

def calculate_embeddings(image_filename):

"""
Calculate embeddings for the provided image.

Args:
image_filename (str): The path to the image file.

Returns:
list: A list of embeddings for the image.
"""

face_image_data = DeepFace.extract_faces(
image_filename, enforce_detection=False,
)
new_image_path = f'Images/Faces/tmp.jpg'

if face_image_data[0]['face'] is not None:
plt.imsave(new_image_path, face_image_data[0]['face'])

img_array = load_and_preprocess_image(new_image_path)
model=load_model('Model/embedding_trial3.h5')
embedding = model.predict(img_array)[0]
embedding_list = embedding.tolist()
logging.info(f'Embedding created')

return embedding_list

@router.post('/recalculate_embeddings')
async def recalculate_embeddings():
"""
Recalculate embeddings for all the images in the database.

Returns:
dict: A dictionary with a success message.

Raises:
None
"""
logging.info('Recalculating embeddings')
employees_mongo = client2.find(collection2)
for employee in employees_mongo:
print(employee, type(employee))

Check failure

Code scanning / CodeQL

Clear-text logging of sensitive information High

This expression logs
sensitive data (private)
Loading
as clear text.
This expression logs
sensitive data (private)
Loading
as clear text.
embeddings = []

# In the initial version, the images were stored in the 'Image' field
if 'Images' in employee:
images = employee['Images']
else:
images = [employee['Image']]

for encoded_image in images:

pil_image = Image.open(BytesIO(base64.b64decode(encoded_image)))
image_filename = f'{employee["Name"]}.png'
pil_image.save(image_filename)
logging.debug(f'Image saved {employee["Name"]}')

Check failure

Code scanning / CodeQL

Clear-text logging of sensitive information High

This expression logs
sensitive data (private)
Loading
as clear text.
This expression logs
sensitive data (private)
Loading
as clear text.
embeddings.append(calculate_embeddings(image_filename))
# os.remove(image_filename)

logging.debug(f'About to update Embeddings: {embeddings}')
# Store the data in the database
client2.update_one(
collection2,
{'EmployeeCode': employee['EmployeeCode']},
{'$set': {'embeddings': embeddings, 'Images': images}},
)

return {'message': 'Embeddings Recalculated successfully'}


# To create new entries of employee
@router.post('/create_new_faceEntry')
Expand All @@ -74,7 +154,7 @@
'\r\n',
'',
).replace('\n', '')
EmployeeCode = Employee.EmployeeCode.replace('\r\n', '').replace('\n', '')
EmployeeCode = Employee.EmployeeCode
gender = Employee.gender.replace('\r\n', '').replace('\n', '')
Department = Employee.Department.replace('\r\n', '').replace('\n', '')
encoded_images = Employee.Images
Comment on lines 154 to 160
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CODE REVIEW

Consider simplifying and enhancing code readability by removing unnecessary .replace functions. Also, ensure code consistency by following a consistent naming convention.

EmployeeCode = Employee.EmployeeCode
gender = Employee.gender
Department = Employee.Department
encoded_images = Employee.Images

Expand All @@ -88,17 +168,13 @@
image_filename = f'{Name}.png'
pil_image.save(image_filename)
pil_image.save(fr'Images\dbImages\{Name}.jpg')
face_image_data = DeepFace.extract_faces(
image_filename, detector_backend='mtcnn', enforce_detection=False,
)
plt.imsave(f'Images/Faces/{Name}.jpg', face_image_data[0]['face'])
logging.info(f'Face saved {Name}')
embedding = DeepFace.represent(
image_filename, model_name='Facenet512', detector_backend='mtcnn',
)
embeddings.append(embedding)
logging.info(f'Embedding created Embeddings for {Name}')
os.remove(image_filename)
# embedding = DeepFace.represent(
# image_filename, model_name='Facenet512', detector_backend='mtcnn',
# )

embeddings.append(calculate_embeddings(image_filename))
# os.remove(image_filename)

logging.debug(f'About to insert Embeddings: {embeddings}')
# Store the data in the database
Comment on lines 168 to 180
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CODE REVIEW

Consider creating a separate function for calculating embeddings to improve code readability and maintainability.

def calculate_embeddings(image_filename):
    return DeepFace.represent(
        image_filename, model_name='Facenet512', detector_backend='mtcnn',
    )

This allows for easier testing and potential reuse in the future.

Expand Down Expand Up @@ -128,8 +204,8 @@
list[Employee]: A list of Employee objects containing employee information.
"""
logging.info('Displaying all employees')
employees_mongo = client.find(collection)
employees_mongo = client2.find(collection2)
logging.info(f'Employees found {employees_mongo}')

Check failure

Code scanning / CodeQL

Clear-text logging of sensitive information High

This expression logs
sensitive data (private)
Loading
as clear text.
employees = [
Employee(
Comment on lines 204 to 210
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CODE REVIEW

Consider adding more descriptive variable names for clarity. Utilize type hints for better code readability.

    employees_mongo = client.find(collection)  # consider renaming to employees_mongo = client.find_employee_data(collection)

EmployeeCode=int(employee.get('EmployeeCode', 0)),
Expand Down Expand Up @@ -162,8 +238,8 @@
logging.debug(f'Display information for {EmployeeCode}')
try:
logging.debug(f'Start {EmployeeCode}')
items = client.find_one(
collection,
items = client2.find_one(
collection2,
filter={'EmployeeCode': EmployeeCode},
projection={
'Name': True,
Comment on lines 238 to 245
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CODE REVIEW

  • Consider using consistent variable naming for improved readability.
  • Utilize logging levels effectively for better debugging.
logger.debug(f'Display information for {EmployeeCode}')
try:
    logger.info(f'Start {EmployeeCode}')
    items = client2.find_one(
        collection2,
        filter={'EmployeeCode': EmployeeCode},
        projection={'Name': True}
    )

Expand Down Expand Up @@ -210,8 +286,8 @@
"""
logging.debug(f'Updating for EmployeeCode: {EmployeeCode}')
try:
user_id = client.find_one(
collection, {'EmployeeCode': EmployeeCode}, projection={'_id': True},
user_id = client2.find_one(
collection2, {'EmployeeCode': EmployeeCode}, projection={'_id': True},
)
print(user_id)
if not user_id:
Comment on lines 286 to 293
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CODE REVIEW

It's good practice to use meaningful variable names. Consider renaming client to something like previous_client for clarity. Also, ensure consistency in variable naming (collection vs collection2). Lastly, consider handling potential exceptions when calling client2.find_one.

previous_client = client
new_client = client2
user_id = new_client.find_one(
    new_collection, {'EmployeeCode': EmployeeCode}, projection={'_id': True},
)

Expand All @@ -229,20 +305,19 @@
image_filename = f'{Employee.Name}.png'
pil_image.save(image_filename)
logging.debug(f'Image saved {Employee.Name}')
face_image_data = DeepFace.extract_faces(
image_filename, detector_backend='mtcnn', enforce_detection=False,
)
embedding = DeepFace.represent(
image_filename, model_name='Facenet', detector_backend='mtcnn',
)
logging.debug(f'Embedding created {Employee.Name}')
embeddings.append(embedding)
os.remove(image_filename)

# embedding = DeepFace.represent(
# image_filename, model_name='Facenet', detector_backend='mtcnn',
# )

embeddings.append(calculate_embeddings(image_filename))
# os.remove(image_filename)

Employee_data['embeddings'] = embeddings

try:
update_result = client.update_one(
collection,
update_result = client2.update_one(
collection2,
{'_id': ObjectId(user_id['_id'])},
update={'$set': Employee_data},
)
Comment on lines 305 to 323
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CODE REVIEW

Consider removing commented-out code for clarity. Simplify by extracting the logic for computing embeddings into a separate function for better separation of concerns.

def calculate_embeddings(image_filename):
    embedding = DeepFace.represent(
        image_filename, model_name='Facenet', detector_backend='mtcnn',
    )
    return embedding

Expand Down Expand Up @@ -285,7 +360,7 @@
"""
logging.info('Deleting Employee')
logging.debug(f'Deleting for EmployeeCode: {EmployeeCode}')
client.find_one_and_delete(collection, {'EmployeeCode': EmployeeCode})
client2.find_one_and_delete(collection2, {'EmployeeCode': EmployeeCode})

return {'Message': 'Successfully Deleted'}

Comment on lines 360 to 366
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CODE REVIEW

Consider abstracting the database client logic to improve modularity and maintainability.

def delete_employee(client, collection, EmployeeCode):
    client.find_one_and_delete(collection, {'EmployeeCode': EmployeeCode})

Expand All @@ -306,20 +381,38 @@
"""
logging.info('Recognizing Face')
try:
# Code to calculate embeddings via Original Facenet model

img_data = await Face.read()
with open('temp.png', 'wb') as f:
image_filename = 'temp.png'
with open(image_filename, 'wb') as f:
f.write(img_data)

embedding = DeepFace.represent(
img_path='temp.png', model_name='Facenet512', detector_backend='mtcnn',
# embedding = DeepFace.represent(
# img_path='temp.png', model_name='Facenet512', detector_backend='mtcnn',
# )

# Code to calculate embeddings via Finetuned Facenet model
face_image_data = DeepFace.extract_faces(
image_filename, detector_backend='mtcnn', enforce_detection=False,
)
result = client2.vector_search(collection2, embedding[0]['embedding'])
logging.info(f"Result: {result[0]['Name']}, {result[0]['score']}")
os.remove('temp.png')
if result[0]['score'] < 0.5:
return Response(
status_code=404, content=json.dumps({'message': 'No match found'}),
)

if face_image_data and face_image_data[0]['face'] is not None:

plt.imsave(f'Images/Faces/tmp.jpg', face_image_data[0]['face'])
face_image_path = f'Images/Faces/tmp.jpg'
img_array = load_and_preprocess_image(face_image_path)

model = load_model('Model/embedding_trial3.h5')
embedding_list = model.predict(img_array)[0] # Get the first prediction
print(embedding_list, type(embedding_list))
embedding = embedding_list.tolist()
result = client2.vector_search(collection3, embedding)
logging.info(f"Result: {result[0]['Name']}, {result[0]['score']}")
os.remove('temp.png')
if result[0]['score'] < 0.5:
return Response(
status_code=404, content=json.dumps({'message': 'No match found'}),
)
except Exception as e:
logging.error(f'Error: {e}')
os.remove('temp.png')
Expand Down
Loading
Loading