khushalps/api_utils_converse_v2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

(20241231)

Browse Source
This commit is contained in:
khushal
2024-12-31 07:41:01 +00:00
parent a07c762586
commit ea594b92b2
2 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
playground/socketio/to_kafka.py
+6 -6
View File
@@ -90,12 +90,12 @@ kafka_producer = ProducerKafka(
bootstrap_servers = "del.ditscentre.in:9092", bootstrap_servers = "del.ditscentre.in:9092",
# buffer_memory = 3_35_54_432, # buffer_memory = 3_35_54_432,
security_protocol = "SSL", security_protocol = "SSL",
ca_file = r"../../creds/kafka/cert_authority.pem", # ca_file = r"../../creds/kafka/cert_authority.pem",
cert_file = r"../../creds/kafka/fullchain.pem", # cert_file = r"../../creds/kafka/fullchain.pem",
key_file = r"../../creds/kafka/privkey.pem" # key_file = r"../../creds/kafka/privkey.pem"
# ca_file = os.path.join(parent_dir, "creds", "kafka", "cert_authority.pem"), ca_file = "/etc/ssl/dbu/ca.pem",
# cert_file = os.path.join(parent_dir, "creds", "kafka", "fullchain.pem"), cert_file = "/etc/ssl/dbu/fullchain.pem",
# key_file = os.path.join(parent_dir, "creds", "kafka", "privkey.pem") key_file = "/etc/ssl/dbu/privkey.pem"
), ),
debug = False debug = False
) )
wsio/finstitutions/trading/main.py
+6 -6
View File
@@ -349,12 +349,12 @@ async def init():
cwd = files.get_cwd() cwd = files.get_cwd()
parent_dir = cwd parent_dir = cwd
ssl_context = get_ssl_context( ssl_context = get_ssl_context(
# ca_file = "/etc/ssl/dbu/ca.pem", ca_file = "/etc/ssl/dbu/ca.pem",
# cert_file = "/etc/ssl/dbu/fullchain.pem", cert_file = "/etc/ssl/dbu/fullchain.pem",
# key_file = "/etc/ssl/dbu/privkey.pem" key_file = "/etc/ssl/dbu/privkey.pem"
ca_file = os.path.join(parent_dir, "creds", "kafka", "cert_authority.pem"), # ca_file = os.path.join(parent_dir, "creds", "kafka", "cert_authority.pem"),
cert_file = os.path.join(parent_dir, "creds", "kafka", "fullchain.pem"), # cert_file = os.path.join(parent_dir, "creds", "kafka", "fullchain.pem"),
key_file = os.path.join(parent_dir, "creds", "kafka", "privkey.pem") # key_file = os.path.join(parent_dir, "creds", "kafka", "privkey.pem")
) )
sio.start_background_task( sio.start_background_task(
ticks_from_kafka, ticks_from_kafka,