Create Redis/PostgreSQL component files and start containers if available.
(components_dir: str = "./components", overwrite: bool = False)
| 480 | |
| 481 | |
| 482 | def setup_environment(components_dir: str = "./components", overwrite: bool = False) -> None: |
| 483 | """Create Redis/PostgreSQL component files and start containers if available.""" |
| 484 | components_path = Path(components_dir) |
| 485 | components_path.mkdir(parents=True, exist_ok=True) |
| 486 | |
| 487 | redis_component = """ |
| 488 | apiVersion: dapr.io/v1alpha1 |
| 489 | kind: Component |
| 490 | metadata: |
| 491 | name: statestore-redis |
| 492 | spec: |
| 493 | type: state.redis |
| 494 | version: v1 |
| 495 | metadata: |
| 496 | - name: redisHost |
| 497 | value: localhost:6379 |
| 498 | - name: redisPassword |
| 499 | value: "" |
| 500 | """.lstrip() |
| 501 | |
| 502 | postgres_component = """ |
| 503 | apiVersion: dapr.io/v1alpha1 |
| 504 | kind: Component |
| 505 | metadata: |
| 506 | name: statestore-postgres |
| 507 | spec: |
| 508 | type: state.postgresql |
| 509 | version: v2 |
| 510 | metadata: |
| 511 | - name: connectionString |
| 512 | value: "host=localhost user=postgres password=postgres dbname=dapr port=5432" |
| 513 | """.lstrip() |
| 514 | |
| 515 | default_component = """ |
| 516 | apiVersion: dapr.io/v1alpha1 |
| 517 | kind: Component |
| 518 | metadata: |
| 519 | name: statestore |
| 520 | spec: |
| 521 | type: state.redis |
| 522 | version: v1 |
| 523 | metadata: |
| 524 | - name: redisHost |
| 525 | value: localhost:6379 |
| 526 | - name: redisPassword |
| 527 | value: "" |
| 528 | """.lstrip() |
| 529 | |
| 530 | _write_text_file(components_path / "statestore-redis.yaml", redis_component, overwrite) |
| 531 | _write_text_file(components_path / "statestore-postgres.yaml", postgres_component, overwrite) |
| 532 | _write_text_file(components_path / "statestore.yaml", default_component, overwrite) |
| 533 | |
| 534 | print(f"Components written under: {components_path.resolve()}") |
| 535 | |
| 536 | _ensure_container("dapr_redis", ["-p", "6379:6379", "redis:7-alpine"]) |
| 537 | _ensure_container( |
| 538 | "dapr_postgres", |
| 539 | [ |
no test coverage detected