crss-meterprocess-stream-source-daily-raw.yml 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091
  1. #daily extract
  2. spring:
  3. profiles: dailyExtract
  4. datasource:
  5. url: jdbc:edb://${crss.database.ip}:5432/crss?currentSchema=metering&ApplicationName=streamingSource
  6. username: crss_metering
  7. password: Fh7UcXpW
  8. driver-class-name: com.edb.Driver
  9. connectionTimeout: 150000
  10. maximumPoolSize: 3
  11. test-on-borrow: true
  12. validation-query: SELECT 1
  13. cloud:
  14. stream:
  15. bindings:
  16. output:
  17. content-type: application/json
  18. jdbc:
  19. query: "select * from metering.txn_meter_data_daily where consumed <> TRUE or consumed is null limit 10000;"
  20. update: "update metering.txn_meter_data_daily set consumed = TRUE where meter_data_id in (:meter_data_id);"
  21. trigger:
  22. fixed-delay: 5
  23. time-unit: SECONDS
  24. logging:
  25. level:
  26. com.pemc: DEBUG
  27. ---
  28. #Monthly extract
  29. spring:
  30. profiles: monthlyExtract
  31. datasource:
  32. url: jdbc:edb://${crss.database.ip}:5432/crss?currentSchema=metering
  33. username: crss_metering
  34. password: Fh7UcXpW
  35. driver-class-name: com.edb.Driver
  36. maximumPoolSize: 2
  37. test-on-borrow: true
  38. validation-query: SELECT 1
  39. cloud:
  40. stream:
  41. bindings:
  42. output:
  43. content-type: application/json
  44. jdbc:
  45. query: "select * from metering.txn_meter_data_monthly where consumed <> TRUE or consumed is null limit 10000;"
  46. update: "update metering.txn_meter_data_monthly set consumed = TRUE where meter_data_id in (:meter_data_id);"
  47. trigger:
  48. fixed-delay: 5
  49. time-unit: SECONDS
  50. logging:
  51. level:
  52. com.pemc: DEBUG
  53. ---
  54. # default
  55. spring:
  56. datasource:
  57. url: jdbc:edb://${crss.database.ip}:5432/crss?currentSchema=metering
  58. username: crss_metering
  59. password: Fh7UcXpW
  60. driver-class-name: com.edb.Driver
  61. maximumPoolSize: 2
  62. test-on-borrow: true
  63. validation-query: SELECT 1
  64. cloud:
  65. stream:
  66. bindings:
  67. output:
  68. content-type: application/json
  69. jdbc:
  70. query: "select * from metering.txn_meter_data_monthly where consumed <> TRUE or consumed is null limit 10000;"
  71. update: "update metering.txn_meter_data_monthly set consumed = TRUE where meter_data_id in (:meter_data_id);"
  72. trigger:
  73. fixed-delay: 5
  74. time-unit: SECONDS
  75. logging:
  76. level:
  77. com.pemc: DEBUG