from cassandra.cqlengine import columns
from cassandra.cqlengine.models import Model
class HosCartDetails(Model):
__keyspace__ = 'hobs_ods_staging'
hoscd_event_date = columns.Date(primary_key=True)
hoscd_businessid = columns.Text(primary_key=True)
hoscd_key = columns.Text(primary_key=True)
hoscd_buid = columns.Text()
hoscd_createdtime = columns.DateTime()
hoscd_opid = columns.Text()
hoscd_status = columns.Text()
hoscd_type = columns.Text()
hoscd_updatedtime = columns.DateTime()
hoscd_username = columns.Text()
hoscd_value = columns.Blob()
hoscd_valuetype = columns.Text()
from flask import Flask, jsonify
from cassandra.cluster import Cluster
from cassandra.auth import PlainTextAuthProvider
from cassandra.cqlengine import connection
from cassandra.cqlengine.management import sync_table
from models import HosCartDetails
app = Flask(__name__)
# Connect to the Cassandra cluster
auth_provider = PlainTextAuthProvider(username='hobs_analytics', password='hobs_analytics')
cluster = Cluster(['172.16.177.58'], auth_provider=auth_provider)
session = cluster.connect()
# Set up the connection for the model
connection.set_session(session)
# Sync the table with the model
sync_table(HosCartDetails)
@app.route('/hos_cart_details/<event_date>')
def get_hos_cart_details(event_date):
# Fetch hoscd_event_date details using the model class
results = HosCartDetails.objects.filter(hoscd_event_date=event_date)
data = [{'hoscd_businessid': r.hoscd_businessid, 'hoscd_key': r.hoscd_key} for r in results]
return jsonify(data)
if __name__ == '__main__':
app.run(debug=True)