Create utils/amc.py
Browse files- utils/amc.py +21 -0
utils/amc.py
ADDED
|
@@ -0,0 +1,21 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1 |
+
```
|
| 2 |
+
import pandas as pd
|
| 3 |
+
from datetime import datetime, timedelta
|
| 4 |
+
import logging
|
| 5 |
+
|
| 6 |
+
logger = logging.getLogger(__name__)
|
| 7 |
+
|
| 8 |
+
def upcoming_amc_devices(df):
|
| 9 |
+
"""Identify devices with upcoming AMC expiries."""
|
| 10 |
+
logger.info("Processing AMC expiries...")
|
| 11 |
+
try:
|
| 12 |
+
df["amc_expiry"] = pd.to_datetime(df["amc_expiry"])
|
| 13 |
+
today = datetime.now()
|
| 14 |
+
threshold = today + timedelta(days=14)
|
| 15 |
+
amc_df = df[df["amc_expiry"] <= threshold][["equipment", "amc_expiry"]]
|
| 16 |
+
logger.info(f"Found {len(amc_df)} devices with upcoming AMC expiries.")
|
| 17 |
+
return amc_df
|
| 18 |
+
except Exception as e:
|
| 19 |
+
logger.error(f"Failed to process AMC expiries: {e}")
|
| 20 |
+
raise
|
| 21 |
+
```
|