Visitar URL original
"deeplabcut.filterpredictions" and "deeplabcut.analyze_skeleton" return mappings by rahulporuri · Pull Request #1908 · DeepLabCut/DeepLabCut · GitHub
Skip to content

"deeplabcut.filterpredictions" and "deeplabcut.analyze_skeleton" return mappings #1908

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

Merged
jeylau merged 7 commits into from
Oct 13, 2023
Merged

"deeplabcut.filterpredictions" and "deeplabcut.analyze_skeleton" return mappings #1908

Show file tree
Hide file tree
Changes from 6 commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
eff4142
REF: Denest filterpredictions for loop
Jul 16, 2022
59ac8ed
REF: Reduce the code within the try block
Jul 16, 2022
8a0efd9
FEAT: Return video filename to filtered dataframe mapping
Jul 16, 2022
b598c33
REF: Reduce scope of try/except
Jul 16, 2022
61ac8f5
FIX: Actually return the mapping
Jul 16, 2022
b6b408d
FEAT: Return mapping from video filename to skeleton dataframe
Jul 16, 2022
6e7e47e
Add return_data flag
jeylau Oct 3, 2023
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
59 changes: 35 additions & 24 deletions deeplabcut/post_processing/analyze_skeleton.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -230,13 +230,20 @@ def analyzeskeleton(

Returns
-------
None
video_to_skeleton_df
Dictionary mapping video filepaths to skeleton dataframes.

* If no videos exist, the dictionary will be empty.
* If a video is not analyzed, the corresponding value in the dictionary will be
None.
"""
# Load config file, scorer and videos
cfg = auxiliaryfunctions.read_config(config)
if not cfg["skeleton"]:
raise ValueError("No skeleton defined in the config.yaml.")

video_to_skeleton_df = {}

track_method = auxfun_multianimal.get_track_method(cfg, track_method=track_method)
DLCscorer, DLCscorerlegacy = auxiliaryfunctions.GetScorerName(
cfg,
Expand All @@ -256,33 +263,37 @@ def analyzeskeleton(
df, filepath, scorer, _ = auxiliaryfunctions.load_analyzed_data(
destfolder, vname, DLCscorer, filtered, track_method
)
output_name = filepath.replace(".h5", f"_skeleton.h5")
if os.path.isfile(output_name):
print(f"Skeleton in video {vname} already processed. Skipping...")
continue

bones = {}
if "individuals" in df.columns.names:
for animal_name, df_ in df.groupby(level="individuals", axis=1):
temp = df_.droplevel(["scorer", "individuals"], axis=1)
if animal_name != "single":
for bp1, bp2 in cfg["skeleton"]:
name = "{}_{}_{}".format(animal_name, bp1, bp2)
bones[name] = analyzebone(temp[bp1], temp[bp2])
else:
for bp1, bp2 in cfg["skeleton"]:
name = "{}_{}".format(bp1, bp2)
bones[name] = analyzebone(df[scorer][bp1], df[scorer][bp2])

skeleton = pd.concat(bones, axis=1)
skeleton.to_hdf(output_name, "df_with_missing", format="table", mode="w")
if save_as_csv:
skeleton.to_csv(output_name.replace(".h5", ".csv"))

except FileNotFoundError as e:
print(e)
video_to_skeleton_df[video] = None
continue

output_name = filepath.replace(".h5", f"_skeleton.h5")
if os.path.isfile(output_name):
print(f"Skeleton in video {vname} already processed. Skipping...")
video_to_skeleton_df[video] = pd.read_hdf(output_name, "df_with_missing")
continue

bones = {}
if "individuals" in df.columns.names:
for animal_name, df_ in df.groupby(level="individuals", axis=1):
temp = df_.droplevel(["scorer", "individuals"], axis=1)
if animal_name != "single":
for bp1, bp2 in cfg["skeleton"]:
name = "{}_{}_{}".format(animal_name, bp1, bp2)
bones[name] = analyzebone(temp[bp1], temp[bp2])
else:
for bp1, bp2 in cfg["skeleton"]:
name = "{}_{}".format(bp1, bp2)
bones[name] = analyzebone(df[scorer][bp1], df[scorer][bp2])

skeleton = pd.concat(bones, axis=1)
video_to_skeleton_df[video] = skeleton
skeleton.to_hdf(output_name, "df_with_missing", format="table", mode="w")
if save_as_csv:
skeleton.to_csv(output_name.replace(".h5", ".csv"))
return video_to_skeleton_df


if __name__ == "__main__":
parser = argparse.ArgumentParser()
Expand Down
140 changes: 79 additions & 61 deletions deeplabcut/post_processing/filtering.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -148,7 +148,12 @@ def filterpredictions(

Returns
-------
None
video_to_filtered_df
Dictionary mapping video filepaths to filtered dataframes.

* If no videos exist, the dictionary will be empty.
* If a video is not analyzed, the corresponding value in the dictionary will be
None.

Examples
--------
Expand Down Expand Up @@ -200,9 +205,11 @@ def filterpredictions(
)
Videos = auxiliaryfunctions.get_list_of_videos(video, videotype)

video_to_filtered_df = {}

if not len(Videos):
print("No video(s) were found. Please check your paths and/or 'videotype'.")
return
return video_to_filtered_df

for video in Videos:
if destfolder is None:
Expand All @@ -212,69 +219,80 @@ def filterpredictions(
vname = Path(video).stem

try:
_ = auxiliaryfunctions.load_analyzed_data(
df, filepath, _, _ = auxiliaryfunctions.load_analyzed_data(
destfolder, vname, DLCscorer, True, track_method
)
print(f"Data from {vname} were already filtered. Skipping...")
except FileNotFoundError: # Data haven't been filtered yet
try:
df, filepath, _, _ = auxiliaryfunctions.load_analyzed_data(
destfolder, vname, DLCscorer, track_method=track_method
video_to_filtered_df[video] = df
# Data has been filtered so continue to the next video
continue
except FileNotFoundError:
pass

# Data haven't been filtered yet
try:
df, filepath, _, _ = auxiliaryfunctions.load_analyzed_data(
destfolder, vname, DLCscorer, track_method=track_method
)
except FileNotFoundError as e:
video_to_filtered_df[video] = None
print(e)
continue

nrows = df.shape[0]
if filtertype == "arima":
temp = df.values.reshape((nrows, -1, 3))
placeholder = np.empty_like(temp)
for i in range(temp.shape[1]):
x, y, p = temp[:, i].T
meanx, _ = FitSARIMAXModel(
x, p, p_bound, alpha, ARdegree, MAdegree, False
)
meany, _ = FitSARIMAXModel(
y, p, p_bound, alpha, ARdegree, MAdegree, False
)
nrows = df.shape[0]
if filtertype == "arima":
temp = df.values.reshape((nrows, -1, 3))
placeholder = np.empty_like(temp)
for i in range(temp.shape[1]):
x, y, p = temp[:, i].T
meanx, _ = FitSARIMAXModel(
x, p, p_bound, alpha, ARdegree, MAdegree, False
)
meany, _ = FitSARIMAXModel(
y, p, p_bound, alpha, ARdegree, MAdegree, False
)
meanx[0] = x[0]
meany[0] = y[0]
placeholder[:, i] = np.c_[meanx, meany, p]
data = pd.DataFrame(
placeholder.reshape((nrows, -1)),
columns=df.columns,
index=df.index,
)
elif filtertype == "median":
data = df.copy()
mask = data.columns.get_level_values("coords") != "likelihood"
data.loc[:, mask] = df.loc[:, mask].apply(
signal.medfilt, args=(windowlength,), axis=0
)
elif filtertype == "spline":
data = df.copy()
mask_data = data.columns.get_level_values("coords").isin(("x", "y"))
xy = data.loc[:, mask_data].values
prob = data.loc[:, ~mask_data].values
missing = np.isnan(xy)
xy_filled = columnwise_spline_interp(xy, windowlength)
filled = ~np.isnan(xy_filled)
xy[filled] = xy_filled[filled]
inds = np.argwhere(missing & filled)
if inds.size:
# Retrieve original individual label indices
inds[:, 1] //= 2
inds = np.unique(inds, axis=0)
prob[inds[:, 0], inds[:, 1]] = 0.01
data.loc[:, ~mask_data] = prob
data.loc[:, mask_data] = xy
else:
raise ValueError(f"Unknown filter type {filtertype}")

outdataname = filepath.replace(".h5", "_filtered.h5")
data.to_hdf(outdataname, "df_with_missing", format="table", mode="w")
if save_as_csv:
print("Saving filtered csv poses!")
data.to_csv(outdataname.split(".h5")[0] + ".csv")
except FileNotFoundError as e:
print(e)
continue
meanx[0] = x[0]
meany[0] = y[0]
placeholder[:, i] = np.c_[meanx, meany, p]
data = pd.DataFrame(
placeholder.reshape((nrows, -1)),
columns=df.columns,
index=df.index,
)
elif filtertype == "median":
data = df.copy()
mask = data.columns.get_level_values("coords") != "likelihood"
data.loc[:, mask] = df.loc[:, mask].apply(
signal.medfilt, args=(windowlength,), axis=0
)
elif filtertype == "spline":
data = df.copy()
mask_data = data.columns.get_level_values("coords").isin(("x", "y"))
xy = data.loc[:, mask_data].values
prob = data.loc[:, ~mask_data].values
missing = np.isnan(xy)
xy_filled = columnwise_spline_interp(xy, windowlength)
filled = ~np.isnan(xy_filled)
xy[filled] = xy_filled[filled]
inds = np.argwhere(missing & filled)
if inds.size:
# Retrieve original individual label indices
inds[:, 1] //= 2
inds = np.unique(inds, axis=0)
prob[inds[:, 0], inds[:, 1]] = 0.01
data.loc[:, ~mask_data] = prob
data.loc[:, mask_data] = xy
else:
raise ValueError(f"Unknown filter type {filtertype}")

video_to_filtered_df[video] = data

outdataname = filepath.replace(".h5", "_filtered.h5")
data.to_hdf(outdataname, "df_with_missing", format="table", mode="w")
if save_as_csv:
print("Saving filtered csv poses!")
data.to_csv(outdataname.split(".h5")[0] + ".csv")
return video_to_filtered_df


if __name__ == "__main__":
Expand Down