-
Notifications
You must be signed in to change notification settings - Fork 7
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'main' into version-update
- Loading branch information
Showing
82 changed files
with
1,829 additions
and
1,875 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
60 changes: 45 additions & 15 deletions
60
analytics-datastore-clickhouse/importer/config/clickhouseTables.js
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,22 +1,52 @@ | ||
const CLUSTERED_MODE = process.env.CLUSTERED_MODE || 'true'; | ||
const CLUSTERED_MODE = process.env.CLUSTERED_MODE || "false"; | ||
|
||
const queries = | ||
Boolean(CLUSTERED_MODE) === true | ||
CLUSTERED_MODE === "true" | ||
? [ | ||
`CREATE TABLE default_table( | ||
createdAt Date, | ||
updatedAt Date | ||
) | ||
ENGINE=MergeTree | ||
ORDER BY tuple();`, | ||
`CREATE TABLE patient_example ON CLUSTER '{cluster}' ( | ||
id String, | ||
version String NULL, | ||
inserted_at DateTime DEFAULT now(), | ||
last_updated Date NULL, | ||
goldenId String, | ||
patientGivenName String, | ||
patientFamilyName String, | ||
) | ||
ENGINE = ReplicatedMergeTree('/clickhouse/tables/{cluster}/{shard}/{table}', '{replica}') | ||
ORDER BY tuple();`, | ||
`CREATE TABLE observation_example ON CLUSTER '{cluster}' ( | ||
id String, | ||
version String NULL, | ||
inserted_at DateTime DEFAULT now(), | ||
last_updated Date NULL, | ||
observationValue Double, | ||
patientId String, | ||
) | ||
ENGINE = ReplicatedMergeTree('/clickhouse/tables/{cluster}/{shard}/{table}', '{replica}') | ||
ORDER BY tuple();`, | ||
] | ||
: [ | ||
`CREATE TABLE default.default_table ON CLUSTER '{cluster}' ( | ||
createdAt Date, | ||
updatedAt Date | ||
) | ||
ENGINE = ReplicatedMergeTree('/clickhouse/tables/{cluster}/{shard}/{table}', '{replica}') | ||
ORDER BY tuple();`, | ||
: [ | ||
`CREATE TABLE patient_example( | ||
id String, | ||
version String NULL, | ||
inserted_at DateTime DEFAULT now(), | ||
last_updated Date NULL, | ||
goldenId String, | ||
patientGivenName String, | ||
patientFamilyName String, | ||
) | ||
ENGINE=MergeTree | ||
ORDER BY tuple();`, | ||
`CREATE TABLE observation_example( | ||
id String, | ||
version String NULL, | ||
inserted_at DateTime DEFAULT now(), | ||
last_updated Date NULL, | ||
observationValue Double, | ||
patientId String, | ||
) | ||
ENGINE=MergeTree | ||
ORDER BY tuple();`, | ||
]; | ||
|
||
module.exports = queries; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,20 @@ | ||
# General | ||
CLUSTERED_MODE=false | ||
|
||
# Log | ||
DEBUG=0 | ||
BASHLOG_FILE=0 | ||
BASHLOG_FILE_PATH=platform.log | ||
|
||
# Message Bus - Kafka | ||
# !NOTE: Topics should comma seperated, optional include partion and repliction values | ||
# e.g. <topic>:<partions>:<replicationFactor> -> test:3:2 (defaults to <topics>:3:1) | ||
KAFKA_TOPICS=2xx,2xx-async,errors,reprocess,3xx,patient,observation,JeMPI-audit-trail | ||
|
||
# SSO | ||
KC_OPENHIM_SSO_ENABLED=true | ||
OPENHIM_CONSOLE_SHOW_LOGIN=false | ||
KC_JEMPI_SSO_ENABLED=true | ||
REACT_APP_JEMPI_BASE_API_PORT=50001 | ||
KC_SUPERSET_SSO_ENABLED=true | ||
KC_GRAFANA_SSO_ENABLED=true |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,19 @@ | ||
# General | ||
CLUSTERED_MODE=false | ||
|
||
# Log | ||
DEBUG=0 | ||
BASHLOG_FILE=0 | ||
BASHLOG_FILE_PATH=platform.log | ||
|
||
# Message Bus - Kafka | ||
# !NOTE: Topics should comma seperated, optional include partion and repliction values | ||
# e.g. <topic>:<partions>:<replicationFactor> -> test:3:2 (defaults to <topics>:3:1) | ||
KAFKA_TOPICS=2xx,2xx-async,errors,reprocess,3xx,patient,observation,JeMPI-audit-trail | ||
|
||
# SSO | ||
KC_OPENHIM_SSO_ENABLED=true | ||
OPENHIM_CONSOLE_SHOW_LOGIN=false | ||
KC_JEMPI_SSO_ENABLED=true | ||
REACT_APP_JEMPI_BASE_API_PORT=50001 | ||
KC_GRAFANA_SSO_ENABLED=true |
Oops, something went wrong.