sean/slingshot-microservice
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Simplify PgConnection import.

Browse Source
This commit is contained in:
Seán
2026-04-25 22:24:18 +01:00
parent 76c63fc3ef
commit a8349e6813
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
README.md
View File

@@ -14,7 +14,7 @@ assumptions about a microservice:
`write_file` function, and a database ORM `connection`. `write_file` function, and a database ORM `connection`.
3. All microservices must communicate with the shared PostgreSQL database via 3. All microservices must communicate with the shared PostgreSQL database via
an ORM connection passed into `process`. an ORM connection passed into `process`.
- Rust microservices use `diesel::pg::PgConnection`. - Rust microservices use `diesel::PgConnection`.
- Python microservices use `sqlalchemy.engine.base.Connection`. - Python microservices use `sqlalchemy.engine.base.Connection`.
3. The `process` function returns a set of IDs (also `u64`) that are the result 3. The `process` function returns a set of IDs (also `u64`) that are the result
of processing the incoming request. Each of these IDs is also associated of processing the incoming request. Each of these IDs is also associated
@@ -134,7 +134,7 @@ Linux wheel covers all CPython versions ≥ 3.8.
```rust ```rust
use slingshot_microservice::Microservice; use slingshot_microservice::Microservice;
use diesel::pg::PgConnection; use diesel::PgConnection;
use slingshot_microservice::{AnyError, ReadFileFn, WriteFileFn}; use slingshot_microservice::{AnyError, ReadFileFn, WriteFileFn};
use std::io::{Read, Write}; use std::io::{Read, Write};
@@ -235,7 +235,7 @@ Within each `process` pass:
returns an opened local file handle for writing, staging the output for returns an opened local file handle for writing, staging the output for
`s3://{resolved_bucket}/{id}`. `s3://{resolved_bucket}/{id}`.
3. `connection` is an ORM-backed PostgreSQL connection passed into `process` 3. `connection` is an ORM-backed PostgreSQL connection passed into `process`
(`diesel::pg::PgConnection` in Rust, `sqlalchemy.engine.base.Connection` (`diesel::PgConnection` in Rust, `sqlalchemy.engine.base.Connection`
in Python). in Python).
4. After `process` returns, opened files are closed. 4. After `process` returns, opened files are closed.
5. Then staged write files are uploaded to S3 with the AWS SDK, local staged 5. Then staged write files are uploaded to S3 with the AWS SDK, local staged

2
examples/simple.rs
View File

@@ -1,5 +1,5 @@
use slingshot_microservice::{AnyError, Microservice, ReadFileFn, WriteFileFn}; use slingshot_microservice::{AnyError, Microservice, ReadFileFn, WriteFileFn};
use diesel::pg::PgConnection; use diesel::PgConnection;
use std::io::{Read, Write}; use std::io::{Read, Write};
fn process( fn process(

2
src/lib.rs
View File

@@ -15,7 +15,7 @@ use aws_sdk_s3::Client;
use aws_sdk_s3::config::{Credentials, Region}; use aws_sdk_s3::config::{Credentials, Region};
use aws_sdk_s3::primitives::ByteStream; use aws_sdk_s3::primitives::ByteStream;
use diesel::Connection as DieselConnection; use diesel::Connection as DieselConnection;
use diesel::pg::PgConnection; use diesel::PgConnection;
use futures_util::StreamExt; use futures_util::StreamExt;
use lapin::options::{ use lapin::options::{
BasicAckOptions, BasicConsumeOptions, BasicNackOptions, BasicPublishOptions, BasicAckOptions, BasicConsumeOptions, BasicNackOptions, BasicPublishOptions,