migrate 2.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394
  1. #!/usr/bin/python3
  2. import json
  3. import os
  4. import sys
  5. def migrate_volume(volume):
  6. return {
  7. 'type': 'hostPath',
  8. 'hostPathConfig': {
  9. 'hostPath': volume['hostPath']
  10. },
  11. } if volume.get('hostPathEnabled', False) else {
  12. 'type': 'ixVolume',
  13. 'ixVolumeConfig': {
  14. 'datasetName': volume['datasetName'],
  15. },
  16. }
  17. def migrate_common_lib(values):
  18. delete_keys = [
  19. 'web_port', 'hostNetwork', 'cpuLimit', 'memLimit', 'enableResourceLimits',
  20. 'dnsConfig', 'environmentVariables', 'appVolumeMounts', 'postgresAppVolumeMounts',
  21. 'extraAppVolumeMounts', 'ownerUID', 'ownerGID', 'timezone'
  22. ]
  23. values.update({
  24. # Migrate Network
  25. 'haNetwork': {
  26. 'webPort': values['web_port'],
  27. 'hostNetwork': values['hostNetwork'],
  28. },
  29. # Migrate Resources
  30. 'resources': {
  31. 'limits': {
  32. 'cpu': values.get('cpuLimit', '4000m'),
  33. 'memory': values.get('memLimit', '8Gi'),
  34. }
  35. },
  36. 'haID': {
  37. 'user': values.get('ownerUID'),
  38. 'group': values.get('ownerGID'),
  39. },
  40. # Migrate DNS
  41. 'podOptions': {
  42. 'dnsConfig': {
  43. 'options': [
  44. {'name': opt['name'], 'value': opt['value']}
  45. for opt in values.get('dnsConfig', {}).get('options', [])
  46. ]
  47. }
  48. },
  49. # Migrate Config
  50. 'TZ': values.get('timezone'),
  51. 'haConfig': {
  52. 'additionalEnvs': values.get('environmentVariables', []),
  53. },
  54. # Migrate Storage
  55. 'haStorage': {
  56. 'config': migrate_volume(values['appVolumeMounts']['config']),
  57. 'media': migrate_volume(values['appVolumeMounts']['media']),
  58. 'pgData': migrate_volume(values['postgresAppVolumeMounts']['postgres-data']),
  59. 'pgBackup': migrate_volume(values['postgresAppVolumeMounts']['postgres-backup']),
  60. 'additionalStorages': [
  61. {
  62. 'type': 'hostPath',
  63. 'hostPathConfig': {'hostPath': e['hostPath']},
  64. 'mountPath': e['mountPath'],
  65. }
  66. for e in values.get('extraAppVolumeMounts', [])
  67. ],
  68. },
  69. })
  70. for k in delete_keys:
  71. values.pop(k, None)
  72. return values
  73. def migrate(values):
  74. # If this missing, we have already migrated
  75. if not 'appVolumeMounts' in values.keys():
  76. return values
  77. return migrate_common_lib(values)
  78. if __name__ == '__main__':
  79. if len(sys.argv) != 2:
  80. exit(1)
  81. if os.path.exists(sys.argv[1]):
  82. with open(sys.argv[1], 'r') as f:
  83. print(json.dumps(migrate(json.loads(f.read()))))