← Cloudflare Workers VPC / workers-vpc

Workers Binding API

Bindingy VPC poskytují API pro přístup k privátním službám z vašeho Workeru. Oba VPC služby a VPC sítě zpřístupní fetch() metoda pro provoz HTTP. VPC Networks také nabízí connect() metoda pro spojení raw TCP. Rozdíl mezi typy vazby spočívá v rozsahu směrování, ne v rozhraní API.

VPC Service binding směruje požadavky na konkrétního předem registrovaného hostitele a port. Tento Konfigurace VPC Service vždy určuje cíl připojení, i když se jiná adresa URL nebo hostitel nachází v fetch() volání.

• host uvedené v fetch() neřídí směrování. Pouze naplňuje Host hlavička, a při použití https, hodnota Server Name Indication (SNI).
• port uvedené v fetch() se ignoruje: vždy se použije port zadaný v konfiguraci VPC Service.

VPC Network binding poskytuje přístup ke každé službě dostupné prostřednictvím navázaného Cloudflare Tunnel nebo Cloudflare Mesh, včetně tras podsítí a hostname oznámených přes Cloudflare Tunnel nebo Mesh a cílů připojených přes vstupní body Cloudflare WAN (GRE, IPsec nebo CNI). Adresa URL předaná do fetch() nebo adresu předanou do connect() určuje skutečný cíl: hostname nebo IP adresu a port.

Odešle požadavek HTTP na privátní službu prostřednictvím připojeného Cloudflare Tunnel nebo Cloudflare Mesh. K dispozici pro bindingy VPC Service i VPC Network.

const response = await env.MY_BINDING.fetch(resource, options);

• resource (string | URL | Request): adresa URL, kterou chcete načíst. Musí se jednat o absolutní URL adresu včetně protokolu, hostitele a cesty (například http://internal-api/api/users).
• options (volitelný RequestInit): standardní možnosti fetch, včetně:
  • method : metoda HTTP (GET, POST, PUT, DELETE atd.)
  • headers : hlavičky požadavku
  • body : tělo požadavku
  • signal : AbortSignal pro zrušení požadavku

Vrátí Promise<Response> která se přeloží na standardní objekt Response rozhraní Fetch API ↗.

Následující příklady platí jak pro bindingy VPC Service, tak pro VPC Network.

export default {
	async fetch(request, env) {
		const privateRequest = new Request(
			"http://internal-api.company.local/users",
		);
		const response = await env.MY_BINDING.fetch(privateRequest);
		const users = await response.json();

		return new Response(JSON.stringify(users), {
			headers: { "Content-Type": "application/json" },
		});
	},
};

export default {
	async fetch(request, env) {
		const privateRequest = new Request(
			"http://internal-api.company.local/users",
			{
				method: "POST",
				headers: {
					"Content-Type": "application/json",
					Authorization: `Bearer ${env.API_TOKEN}`,
				},
				body: JSON.stringify({
					name: "John Doe",
					email: "[email protected]",
				}),
			},
		);

		const response = await env.MY_BINDING.fetch(privateRequest);

		if (!response.ok) {
			return new Response("Failed to create user", { status: response.status });
		}

		const user = await response.json();
		return new Response(JSON.stringify(user), {
			headers: { "Content-Type": "application/json" },
		});
	},
};

export default {
	async fetch(request, env) {
		const privateRequest = new Request("https://10.0.1.50/api/data");
		const response = await env.MY_BINDING.fetch(privateRequest);

		return response;
	},
};

Otevře nezpracované TCP připojení k privátnímu cíli prostřednictvím propojeného Cloudflare Tunnel nebo Cloudflare Mesh. K dispozici pouze u vazeb typu VPC Network.

const socket = await env.MY_BINDING.connect(address);

• address (string | SocketAddress): cíl připojení. Zadejte řetězec ve formátu "host:port" formát (například "10.0.1.50:6379") nebo SocketAddress objekt s hostname a port.

Vrátí Promise<Socket> která se přeloží na Socket hodnotou readable a writable streamy. Pokud connect() se nepodaří navázat spojení, vyvolá výjimku.

export default {
	async fetch(request, env) {
		const socket = await env.MY_BINDING.connect("10.0.1.50:6379");

		const writer = socket.writable.getWriter();
		await writer.write(new TextEncoder().encode("PING\r\n"));
		await writer.close();

		return new Response(socket.readable);
	},
};

export default {
	async fetch(request, env) {
		const socket = await env.MY_BINDING.connect({
			hostname: "10.0.1.50",
			port: 6379,
		});

		const writer = socket.writable.getWriter();
		await writer.write(new TextEncoder().encode("PING\r\n"));
		await writer.close();

		return new Response(socket.readable);
	},
};

Aby bylo možné ve Workeru navázat binding na VPC Service nebo VPC Network, potřebuje váš uživatel Connectivity Directory Bind (nebo Connectivity Directory Admin). Přímé vytvoření vazby na Cloudflare Tunnel prostřednictvím VPC Network binding vyžaduje Connectivity Directory Admin. Definice rolí najdete v Role.

• Nakonfigurujte VPC služby
• Nakonfigurujte VPC sítě
• Viz příklady použití