您的仓库管理数据模板

SELECT
    oh.ord_num AS WarehouseOrder,
    'Warehouse Order Created' AS ActivityName,
    oh.create_date_time AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    NULL AS EndTime,
    oh.create_user_id AS UserOperatorId,
    oh.ord_type AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    oh.req_ship_dttm AS RequestedCompletionDate
FROM ord_hdr oh
WHERE oh.create_date_time BETWEEN '[START_DATE]' AND '[END_DATE]'
AND oh.whse = '[Your Warehouse ID]'

UNION ALL

SELECT
    ah.po_nbr AS WarehouseOrder,
    'Inbound Delivery Notification Rcvd' AS ActivityName,
    ah.create_date_time AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    NULL AS EndTime,
    ah.create_user_id AS UserOperatorId,
    'INBOUND' AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM asn_hdr ah
WHERE ah.create_date_time BETWEEN '[START_DATE]' AND '[END_DATE]'
AND ah.whse = '[Your Warehouse ID]'

UNION ALL

SELECT
    c.ref_value AS WarehouseOrder,
    'Goods Arrived at Dock' AS ActivityName,
    c.check_in_dttm AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    NULL AS EndTime,
    c.user_id AS UserOperatorId,
    'INBOUND' AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM car_move c
WHERE c.ref_field = 'PO' AND c.check_in_dttm BETWEEN '[START_DATE]' AND '[END_DATE]'
AND c.whse = '[Your Warehouse ID]'

UNION ALL

SELECT
    rd.po_nbr AS WarehouseOrder,
    'Goods Received and Counted' AS ActivityName,
    MAX(rd.mod_date_time) AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    NULL AS EndTime,
    MAX(rd.mod_user_id) AS UserOperatorId,
    'INBOUND' AS OrderType,
    rd.item_name AS MaterialId,
    SUM(rd.recvd_qty) AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM rcv_dtl rd
WHERE rd.mod_date_time BETWEEN '[START_DATE]' AND '[END_DATE]'
AND rd.whse = '[Your Warehouse ID]'
GROUP BY rd.po_nbr, rd.item_name

UNION ALL

SELECT
    i.ref_field_1 AS WarehouseOrder,
    'Quality Inspection Performed' AS ActivityName,
    i.tran_dttm AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    NULL AS EndTime,
    i.user_id AS UserOperatorId,
    NULL AS OrderType,
    i.item_name AS MaterialId,
    i.tran_qty AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM invn_adj_hist i
WHERE i.tran_type = 'QC' AND i.tran_dttm BETWEEN '[START_DATE]' AND '[END_DATE]'
AND i.whse = '[Your Warehouse ID]'

UNION ALL

SELECT
    t.ord_num AS WarehouseOrder,
    'Putaway Task Created' AS ActivityName,
    t.create_date_time AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    NULL AS EndTime,
    t.create_user_id AS UserOperatorId,
    'INBOUND' AS OrderType,
    t.item_name AS MaterialId,
    t.orig_qty AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM task_gen_dtl t
WHERE t.task_type = 'PUT' AND t.create_date_time BETWEEN '[START_DATE]' AND '[END_DATE]'
AND t.whse = '[Your Warehouse ID]'

UNION ALL

SELECT
    t.ord_num AS WarehouseOrder,
    'Goods Put Away in Storage' AS ActivityName,
    t.mod_date_time AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    t.mod_date_time AS EndTime,
    t.mod_user_id AS UserOperatorId,
    'INBOUND' AS OrderType,
    t.item_name AS MaterialId,
    t.actl_qty AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM task_gen_dtl t
WHERE t.task_type = 'PUT' AND t.task_stat = 'C' AND t.mod_date_time BETWEEN '[START_DATE]' AND '[END_DATE]'
AND t.whse = '[Your Warehouse ID]'

UNION ALL

SELECT
    t.ord_num AS WarehouseOrder,
    'Picking Task Created' AS ActivityName,
    t.create_date_time AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    NULL AS EndTime,
    t.create_user_id AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    t.item_name AS MaterialId,
    t.orig_qty AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM task_gen_dtl t
WHERE t.task_type = 'PCK' AND t.create_date_time BETWEEN '[START_DATE]' AND '[END_DATE]'
AND t.whse = '[Your Warehouse ID]'

UNION ALL

SELECT
    t.ord_num AS WarehouseOrder,
    'Goods Picked from Storage' AS ActivityName,
    t.mod_date_time AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    t.mod_date_time AS EndTime,
    t.mod_user_id AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    t.item_name AS MaterialId,
    t.actl_qty AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM task_gen_dtl t
WHERE t.task_type = 'PCK' AND t.task_stat = 'C' AND t.mod_date_time BETWEEN '[START_DATE]' AND '[END_DATE]'
AND t.whse = '[Your Warehouse ID]'

UNION ALL

SELECT
    pt.ord_num AS WarehouseOrder,
    'Packing Initiated' AS ActivityName,
    MIN(pt.create_dttm) AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    NULL AS EndTime,
    MIN(pt.user_id) AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM pack_tran pt
WHERE pt.create_dttm BETWEEN '[START_DATE]' AND '[END_DATE]'
AND pt.whse = '[Your Warehouse ID]'
GROUP BY pt.ord_num

UNION ALL

SELECT
    sc.ord_num AS WarehouseOrder,
    'Goods Packed' AS ActivityName,
    sc.mod_date_time AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    NULL AS EndTime,
    sc.mod_user_id AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM ship_carton sc
WHERE sc.stat_code = 'PACKED' AND sc.mod_date_time BETWEEN '[START_DATE]' AND '[END_DATE]'
AND sc.whse = '[Your Warehouse ID]'

UNION ALL

SELECT
    sh.ord_num AS WarehouseOrder,
    'Staging for Shipment' AS ActivityName,
    sh.mod_date_time AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    NULL AS EndTime,
    sh.mod_user_id AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    sh.req_ship_dttm AS RequestedCompletionDate
FROM ship_hdr sh
WHERE sh.stat_code = 'STAGED' AND sh.mod_date_time BETWEEN '[START_DATE]' AND '[END_DATE]'
AND sh.whse = '[Your Warehouse ID]'

UNION ALL

SELECT
    sh.ord_num AS WarehouseOrder,
    'Loading onto Carrier' AS ActivityName,
    sh.mod_date_time AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    NULL AS EndTime,
    sh.mod_user_id AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    sh.req_ship_dttm AS RequestedCompletionDate
FROM ship_hdr sh
WHERE sh.stat_code = 'LOADED' AND sh.mod_date_time BETWEEN '[START_DATE]' AND '[END_DATE]'
AND sh.whse = '[Your Warehouse ID]'

UNION ALL

SELECT
    sh.ord_num AS WarehouseOrder,
    'Shipment Dispatched' AS ActivityName,
    sh.actual_ship_dttm AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    NULL AS EndTime,
    sh.mod_user_id AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    sh.req_ship_dttm AS RequestedCompletionDate
FROM ship_hdr sh
WHERE sh.actual_ship_dttm IS NOT NULL AND sh.actual_ship_dttm BETWEEN '[START_DATE]' AND '[END_DATE]'
AND sh.whse = '[Your Warehouse ID]'

UNION ALL

SELECT
    oh.ord_num AS WarehouseOrder,
    'Warehouse Order Completed' AS ActivityName,
    oh.mod_date_time AS EventTime,
    'Manhattan SCALE' AS SourceSystem,
    GETDATE() AS LastDataUpdate,
    NULL AS EndTime,
    oh.mod_user_id AS UserOperatorId,
    oh.ord_type AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    oh.req_ship_dttm AS RequestedCompletionDate
FROM ord_hdr oh
WHERE oh.ord_stat = 'C' AND oh.mod_date_time BETWEEN '[START_DATE]' AND '[END_DATE]'
AND oh.whse = '[Your Warehouse ID]'

import pandas as pd
import pyodbc
import datetime

class=class="hl-string">"hl-comment"># --- Configuration ---
class=class="hl-string">"hl-comment"># Replace with your database connection details
connection_string = (
    class="hl-string">'DRIVER={ODBC Driver 17 for SQL Server};'
    class="hl-string">'SERVER=[Your_Server_Name];'
    class="hl-string">'DATABASE=[Your_Database_Name];'
    class="hl-string">'UID=[Your_Username];'
    class="hl-string">'PWD=[Your_Password]'
)

class=class="hl-string">"hl-comment"># Define the date range for the extraction
start_date = class="hl-string">'2023-01-01'
end_date = class="hl-string">'2023-06-30'

class=class="hl-string">"hl-comment"># --- SQL Query ---
sql_query = fclass="hl-string">"""
-- Warehouse Order Created
SELECT
    ord.ORDER_ID AS WarehouseOrder,
    'Warehouse Order Created' AS ActivityName,
    ord.CREATE_DATE_TIME AS EventTime,
    ord.LAST_UPDATED_DTTM AS EndTime,
    ord.CREATED_BY AS UserOperatorId,
    ord.ORDER_TYPE AS OrderType,
    ordl.ITEM_NAME AS MaterialId,
    ordl.ORIGINAL_QTY AS ActualQuantity,
    ord.REQUIRED_SHIP_DATE AS RequestedCompletionDate
FROM ORDERS ord
JOIN ORDER_LINE_ITEM ordl ON ord.ORDER_ID = ordl.ORDER_ID
WHERE ord.CREATE_DATE_TIME BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Inbound Delivery Notification Rcvd
SELECT
    asn.PO_NBR AS WarehouseOrder, -- Assuming PO number links to an inbound order
    'Inbound Delivery Notification Rcvd' AS ActivityName,
    asn.CREATED_DTTM AS EventTime,
    asn.LAST_UPDATED_DTTM AS EndTime,
    asn.CREATED_BY AS UserOperatorId,
    'INBOUND' AS OrderType,
    asnd.ITEM_NAME AS MaterialId,
    asnd.EXPECTED_QTY AS ActualQuantity,
    asn.EXPECTED_DELIVERY_DTTM AS RequestedCompletionDate
FROM ASN_HEADER asn
JOIN ASN_DETAIL asnd ON asn.ASN_ID = asnd.ASN_ID
WHERE asn.CREATED_DTTM BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Goods Arrived at Dock
SELECT
    appt.REF_FIELD_1 AS WarehouseOrder, -- Assuming a reference field holds the Order ID
    'Goods Arrived at Dock' AS ActivityName,
    appt.ACTUAL_ARRIVAL_DTTM AS EventTime,
    appt.ACTUAL_DEPARTURE_DTTM AS EndTime,
    appt.CHECK_IN_USER AS UserOperatorId,
    'INBOUND' AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    appt.APPT_DTTM AS RequestedCompletionDate
FROM APPOINTMENT appt
WHERE appt.ACTUAL_ARRIVAL_DTTM IS NOT NULL AND appt.ACTUAL_ARRIVAL_DTTM BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Goods Received and Counted
SELECT
    rcpt.REF_FIELD_1 AS WarehouseOrder,
    'Goods Received and Counted' AS ActivityName,
    rcpt.CREATED_DTTM AS EventTime,
    rcpt.LAST_UPDATED_DTTM AS EndTime,
    rcpt.CREATED_BY AS UserOperatorId,
    'INBOUND' AS OrderType,
    rcpt.ITEM_NAME AS MaterialId,
    rcpt.RECEIVED_QTY AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM RECEIPT_DETAIL rcpt
WHERE rcpt.CREATED_DTTM BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Quality Inspection Performed
SELECT 
    qch.ORDER_ID AS WarehouseOrder,
    'Quality Inspection Performed' AS ActivityName,
    qch.QC_PERFORMED_DTTM AS EventTime,
    qch.QC_PERFORMED_DTTM AS EndTime,
    qch.QC_USER_ID AS UserOperatorId,
    ord.ORDER_TYPE AS OrderType,
    qch.ITEM_NAME AS MaterialId,
    qch.QC_QTY AS ActualQuantity,
    ord.REQUIRED_SHIP_DATE AS RequestedCompletionDate
FROM QC_HISTORY qch
LEFT JOIN ORDERS ord ON qch.ORDER_ID = ord.ORDER_ID
WHERE qch.QC_PERFORMED_DTTM BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Putaway Task Created
SELECT
    td.ORDER_ID AS WarehouseOrder,
    'Putaway Task Created' AS ActivityName,
    td.CREATE_DATE_TIME AS EventTime,
    td.END_DATE_TIME AS EndTime,
    td.CREATE_USER_ID AS UserOperatorId,
    'INBOUND' AS OrderType,
    td.ITEM_NAME AS MaterialId,
    td.TASK_QTY AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM TASK_DETAIL td
WHERE td.TASK_TYPE = 'PUTAWAY' AND td.CREATE_DATE_TIME BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Goods Put Away in Storage
SELECT
    td.ORDER_ID AS WarehouseOrder,
    'Goods Put Away in Storage' AS ActivityName,
    td.END_DATE_TIME AS EventTime,
    td.END_DATE_TIME AS EndTime,
    td.USER_ID AS UserOperatorId,
    'INBOUND' AS OrderType,
    td.ITEM_NAME AS MaterialId,
    td.TASK_QTY AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM TASK_DETAIL td
WHERE td.TASK_TYPE = 'PUTAWAY' AND td.TASK_STATUS = 'COMPLETED' AND td.END_DATE_TIME IS NOT NULL AND td.END_DATE_TIME BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Picking Task Created
SELECT
    td.ORDER_ID AS WarehouseOrder,
    'Picking Task Created' AS ActivityName,
    td.CREATE_DATE_TIME AS EventTime,
    td.END_DATE_TIME AS EndTime,
    td.CREATE_USER_ID AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    td.ITEM_NAME AS MaterialId,
    td.TASK_QTY AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM TASK_DETAIL td
WHERE td.TASK_TYPE = 'PICK' AND td.CREATE_DATE_TIME BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Goods Picked from Storage
SELECT
    td.ORDER_ID AS WarehouseOrder,
    'Goods Picked from Storage' AS ActivityName,
    td.END_DATE_TIME AS EventTime,
    td.END_DATE_TIME AS EndTime,
    td.USER_ID AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    td.ITEM_NAME AS MaterialId,
    td.TASK_QTY AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM TASK_DETAIL td
WHERE td.TASK_TYPE = 'PICK' AND td.TASK_STATUS = 'COMPLETED' AND td.END_DATE_TIME IS NOT NULL AND td.END_DATE_TIME BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Packing Initiated
SELECT 
    ph.ORDER_ID AS WarehouseOrder,
    'Packing Initiated' AS ActivityName,
    ph.PACK_START_DTTM AS EventTime,
    ph.PACK_END_DTTM AS EndTime,
    ph.PACKER_ID AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    ph.ITEM_NAME AS MaterialId,
    ph.PACKED_QTY AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM PACK_HISTORY ph
WHERE ph.PACK_START_DTTM IS NOT NULL AND ph.PACK_START_DTTM BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Goods Packed
SELECT 
    ch.ORDER_ID AS WarehouseOrder,
    'Goods Packed' AS ActivityName,
    ch.PACK_DATE_TIME AS EventTime,
    ch.PACK_DATE_TIME AS EndTime,
    ch.PACK_STATION_OPERATOR AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    cd.ITEM_NAME AS MaterialId,
    cd.PACKED_QTY AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM CARTON_HEADER ch
JOIN CARTON_DETAIL cd ON ch.CARTON_NBR = cd.CARTON_NBR
WHERE ch.PACK_DATE_TIME IS NOT NULL AND ch.PACK_DATE_TIME BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Staging for Shipment
SELECT
    ch.ORDER_ID AS WarehouseOrder,
    'Staging for Shipment' AS ActivityName,
    ch.LAST_UPDATED_DTTM AS EventTime,
    ch.LAST_UPDATED_DTTM AS EndTime,
    ch.LAST_UPDATED_BY AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    NULL AS RequestedCompletionDate
FROM CARTON_HEADER ch
WHERE ch.CARTON_STATUS = 'STAGED' AND ch.LAST_UPDATED_DTTM BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Loading onto Carrier
SELECT
    sh.ORDER_ID AS WarehouseOrder,
    'Loading onto Carrier' AS ActivityName,
    sh.LOAD_DTTM AS EventTime,
    sh.DISPATCH_DTTM AS EndTime,
    sh.LOADED_BY AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    sh.SCHEDULED_SHIP_DTTM AS RequestedCompletionDate
FROM SHIPMENT_HEADER sh
WHERE sh.LOAD_DTTM IS NOT NULL AND sh.LOAD_DTTM BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Shipment Dispatched
SELECT
    sh.ORDER_ID AS WarehouseOrder,
    'Shipment Dispatched' AS ActivityName,
    sh.DISPATCH_DTTM AS EventTime,
    sh.DISPATCH_DTTM AS EndTime,
    sh.DISPATCH_USER AS UserOperatorId,
    'OUTBOUND' AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    sh.SCHEDULED_SHIP_DTTM AS RequestedCompletionDate
FROM SHIPMENT_HEADER sh
WHERE sh.SHIPMENT_STATUS = 'SHIPPED' AND sh.DISPATCH_DTTM IS NOT NULL AND sh.DISPATCH_DTTM BETWEEN '{start_date}' AND '{end_date}'

UNION ALL

-- Warehouse Order Completed
SELECT
    ord.ORDER_ID AS WarehouseOrder,
    'Warehouse Order Completed' AS ActivityName,
    ord.LAST_UPDATED_DTTM AS EventTime,
    ord.LAST_UPDATED_DTTM AS EndTime,
    ord.LAST_UPDATED_BY AS UserOperatorId,
    ord.ORDER_TYPE AS OrderType,
    NULL AS MaterialId,
    NULL AS ActualQuantity,
    ord.REQUIRED_SHIP_DATE AS RequestedCompletionDate
FROM ORDERS ord
WHERE ord.ORDER_STATUS = 'COMPLETED' AND ord.LAST_UPDATED_DTTM BETWEEN '{start_date}' AND '{end_date}'

"""

class=class="hl-string">"hl-comment"># --- Execution and Export ---
try:
    class=class="hl-string">"hl-comment"># Establish connection
    cnxn = pyodbc.connect(connection_string)
    print(class="hl-string">"Connection successful. Executing query...")

    class=class="hl-string">"hl-comment"># Execute the query and load into a pandas DataFrame
    df = pd.read_sql_query(sql_query, cnxn)
    print(fclass="hl-string">"Query finished. {len(df)} rows extracted.")

    class=class="hl-string">"hl-comment"># Add static columns
    df[class="hl-string">'SourceSystem'] = class="hl-string">'Manhattan SCALE'
    df[class="hl-string">'LastDataUpdate'] = datetime.datetime.now().strftime(class="hl-string">"%Y-%m-%d %H:%M:%S")

    class=class="hl-string">"hl-comment"># Sort the data for readability
    df = df.sort_values(by=[class="hl-string">'WarehouseOrder', class="hl-string">'EventTime'])
    
    class=class="hl-string">"hl-comment"># Define the final column order
    column_order = [
        class="hl-string">'WarehouseOrder', class="hl-string">'ActivityName', class="hl-string">'EventTime', class="hl-string">'SourceSystem', class="hl-string">'LastDataUpdate',
        class="hl-string">'EndTime', class="hl-string">'UserOperatorId', class="hl-string">'OrderType', class="hl-string">'MaterialId', class="hl-string">'ActualQuantity',
        class="hl-string">'RequestedCompletionDate'
    ]
    df = df[column_order]

    class=class="hl-string">"hl-comment"># Export to CSV
    output_filename = class="hl-string">'manhattan_scale_event_log.csv'
    df.to_csv(output_filename, index=False, date_format=class="hl-string">'%Y-%m-%d %H:%M:%S.%f')
    print(fclass="hl-string">"Event log saved to {output_filename}")

except Exception as e:
    print(fclass="hl-string">"An error occurred: {e}")

finally:
    class=class="hl-string">"hl-comment"># Close the connection
    if class="hl-string">'cnxn' in locals() and cnxn:
        cnxn.close()
        print(class="hl-string">"Connection closed.")