Untitled
unknown
plain_text
2 years ago
2.9 kB
4
Indexable
from cassandra.cluster import Cluster import pandas as pd from cassandra.auth import PlainTextAuthProvider auth_provider = PlainTextAuthProvider(username='cassandra', password='cassandra@123') cluster = Cluster(['172.16.177.58'], auth_provider=auth_provider) session = cluster.connect('hobs_ods_staging') cassandra_query = "SELECT * FROM hos_event_recon_summary limit 10" result_set = session.execute(cassandra_query) df = pd.DataFrame(result_set, columns=['recon_start_date', 'recon_end_date', 'event_type', 'no_of_failed_events', 'no_of_failed_events_pubished_to_kafka', 'no_of_passed_events', 'no_of_passed_events_via_recon', 'total_no_of_events']) df['recon_start_date'] = pd.to_datetime(df['recon_start_date']).dt.date result_df = df.groupby(['recon_start_date', 'event_type']).agg({ 'total_no_of_events': 'sum', 'no_of_passed_events': 'sum', 'no_of_failed_events': 'sum', 'no_of_passed_events_via_recon': 'sum' }).reset_index() print(result_df) above code is printing is below like from cassandra.cluster import Cluster recon_start_date event_type total_no_of_events no_of_passed_events no_of_failed_events no_of_passed_events_via_recon 0 2023-04-05 addAccount 2 2 0 0 1 2023-05-08 updateSalesOrder 120 120 0 0 2 2023-05-13 addAccount 3 3 0 0 3 2023-05-13 addContact 7 7 0 0 4 2023-05-13 addCustomer 4 4 0 0 5 2023-05-13 addIndividual 28 28 0 0 6 2023-05-13 updatePartyRole 14 14 0 0 7 2023-05-13 updatePartyRoleByAssocId 14 0 14 0 8 2023-05-13 updateSalesOrder 120 120 0 0 9 2023-05-17 updateSalesOrder 120 120 0 0 [13:36:05:hobapp@tcs-hob-sir-env01 ] /app/server/HOBS-DataPipeline_new/modules/devops/dags> now instead of printing can you send that in mail by using smtp i want those in boxes neatly
Editor is loading...
Leave a Comment