লাইভ এপিআই-এ, একটি সেশন একটি স্থায়ী সংযোগকে বোঝায় যেখানে ইনপুট এবং আউটপুট একই সংযোগের মাধ্যমে ক্রমাগত স্ট্রিম করা হয় ( এটি কীভাবে কাজ করে সে সম্পর্কে আরও পড়ুন)। এই অনন্য সেশন ডিজাইন কম লেটেন্সি সক্ষম করে এবং অনন্য বৈশিষ্ট্যগুলিকে সমর্থন করে, তবে সেশনের সময় সীমা এবং প্রাথমিক সমাপ্তির মতো চ্যালেঞ্জগুলিও উপস্থাপন করতে পারে। লাইভ এপিআই ব্যবহার করার সময় যে সেশন ম্যানেজমেন্ট চ্যালেঞ্জগুলি উত্থাপিত হতে পারে সেগুলি কাটিয়ে ওঠার কৌশলগুলি এই নির্দেশিকা কভার করে৷
সেশন জীবনকাল
কম্প্রেশন ছাড়া, অডিও-শুধু সেশন 15 মিনিটের জন্য সীমাবদ্ধ, এবং অডিও-ভিডিও সেশন 2 মিনিটের মধ্যে সীমাবদ্ধ। এই সীমা অতিক্রম করলে সেশনটি বন্ধ হয়ে যাবে (এবং সেই কারণে, সংযোগ), তবে আপনি সেশনগুলিকে সীমাহীন সময়ের জন্য প্রসারিত করতে প্রসঙ্গ উইন্ডো কম্প্রেশন ব্যবহার করতে পারেন।
একটি সংযোগের জীবনকাল প্রায় 10 মিনিটের জন্যও সীমিত। সংযোগ বন্ধ হয়ে গেলে, সেশনটিও বন্ধ হয়ে যায়। এই ক্ষেত্রে, আপনি সেশন পুনঃসূচনা ব্যবহার করে একাধিক সংযোগে সক্রিয় থাকার জন্য একটি একক সেশন কনফিগার করতে পারেন। সংযোগ শেষ হওয়ার আগে আপনি একটি GoAway বার্তাও পাবেন, যা আপনাকে আরও পদক্ষেপ নিতে অনুমতি দেবে।
প্রসঙ্গ উইন্ডো কম্প্রেশন
দীর্ঘতর সেশনগুলি সক্ষম করতে এবং আকস্মিক সংযোগ বন্ধ হওয়া এড়াতে, আপনি সেশন কনফিগারেশনের অংশ হিসাবে প্রসঙ্গ উইন্ডো কম্প্রেশন ক্ষেত্র সেট করে প্রসঙ্গ উইন্ডো কম্প্রেশন সক্ষম করতে পারেন।
ContextWindowCompressionConfig- এ, আপনি একটি স্লাইডিং-উইন্ডো মেকানিজম এবং কম্প্রেশন ট্রিগার করে এমন টোকেনের সংখ্যা কনফিগার করতে পারেন।
পাইথন
from google.genai import types
config = types.LiveConnectConfig(
response_modalities=["AUDIO"],
context_window_compression=(
# Configures compression with default parameters.
types.ContextWindowCompressionConfig(
sliding_window=types.SlidingWindow(),
)
),
)
জাভাস্ক্রিপ্ট
const config = {
responseModalities: [Modality.AUDIO],
contextWindowCompression: { slidingWindow: {} }
};
অধিবেশন পুনঃসূচনা
সার্ভার যখন পর্যায়ক্রমে WebSocket সংযোগ পুনরায় সেট করে তখন সেশন সমাপ্তি প্রতিরোধ করতে, সেটআপ কনফিগারেশনের মধ্যে সেশন রিজাম্পশন ক্ষেত্রটি কনফিগার করুন।
এই কনফিগারেশনটি পাস করার ফলে সার্ভারটি SessionResumptionUpdate বার্তা পাঠাতে পারে, যা পরবর্তী সংযোগের SessionResumptionConfig.handle
হিসাবে শেষ পুনঃসূচনা টোকেনটি পাস করে সেশন পুনরায় শুরু করতে ব্যবহার করা যেতে পারে।
পাইথন
import asyncio
from google import genai
from google.genai import types
client = genai.Client()
model = "gemini-live-2.5-flash-preview"
async def main():
print(f"Connecting to the service with handle {previous_session_handle}...")
async with client.aio.live.connect(
model=model,
config=types.LiveConnectConfig(
response_modalities=["AUDIO"],
session_resumption=types.SessionResumptionConfig(
# The handle of the session to resume is passed here,
# or else None to start a new session.
handle=previous_session_handle
),
),
) as session:
while True:
await session.send_client_content(
turns=types.Content(
role="user", parts=[types.Part(text="Hello world!")]
)
)
async for message in session.receive():
# Periodically, the server will send update messages that may
# contain a handle for the current state of the session.
if message.session_resumption_update:
update = message.session_resumption_update
if update.resumable and update.new_handle:
# The handle should be retained and linked to the session.
return update.new_handle
# For the purposes of this example, placeholder input is continually fed
# to the model. In non-sample code, the model inputs would come from
# the user.
if message.server_content and message.server_content.turn_complete:
break
if __name__ == "__main__":
asyncio.run(main())
জাভাস্ক্রিপ্ট
import { GoogleGenAI, Modality } from '@google/genai';
const ai = new GoogleGenAI({});
const model = 'gemini-live-2.5-flash-preview';
async function live() {
const responseQueue = [];
async function waitMessage() {
let done = false;
let message = undefined;
while (!done) {
message = responseQueue.shift();
if (message) {
done = true;
} else {
await new Promise((resolve) => setTimeout(resolve, 100));
}
}
return message;
}
async function handleTurn() {
const turns = [];
let done = false;
while (!done) {
const message = await waitMessage();
turns.push(message);
if (message.serverContent && message.serverContent.turnComplete) {
done = true;
}
}
return turns;
}
console.debug('Connecting to the service with handle %s...', previousSessionHandle)
const session = await ai.live.connect({
model: model,
callbacks: {
onopen: function () {
console.debug('Opened');
},
onmessage: function (message) {
responseQueue.push(message);
},
onerror: function (e) {
console.debug('Error:', e.message);
},
onclose: function (e) {
console.debug('Close:', e.reason);
},
},
config: {
responseModalities: [Modality.TEXT],
sessionResumption: { handle: previousSessionHandle }
// The handle of the session to resume is passed here, or else null to start a new session.
}
});
const inputTurns = 'Hello how are you?';
session.sendClientContent({ turns: inputTurns });
const turns = await handleTurn();
for (const turn of turns) {
if (turn.sessionResumptionUpdate) {
if (turn.sessionResumptionUpdate.resumable && turn.sessionResumptionUpdate.newHandle) {
let newHandle = turn.sessionResumptionUpdate.newHandle
// ...Store newHandle and start new session with this handle here
}
}
}
session.close();
}
async function main() {
await live().catch((e) => console.error('got error', e));
}
main();
সেশন সংযোগ বিচ্ছিন্ন হওয়ার আগে একটি বার্তা গ্রহণ করা হচ্ছে
সার্ভার একটি GoAway বার্তা পাঠায় যা সংকেত দেয় যে বর্তমান সংযোগটি শীঘ্রই বন্ধ হয়ে যাবে। এই বার্তাটিতে টাইমলেফ্ট অন্তর্ভুক্ত রয়েছে, বাকি সময় নির্দেশ করে এবং সংযোগটি বন্ধ হয়ে যাওয়ার আগে আপনাকে আরও পদক্ষেপ নিতে দেয়।
পাইথন
async for response in session.receive():
if response.go_away is not None:
# The connection will soon be terminated
print(response.go_away.time_left)
জাভাস্ক্রিপ্ট
const turns = await handleTurn();
for (const turn of turns) {
if (turn.goAway) {
console.debug('Time left: %s\n', turn.goAway.timeLeft);
}
}
প্রজন্ম সম্পূর্ণ হলে একটি বার্তা গ্রহণ করা
সার্ভার একটি জেনারেশন কমপ্লিট মেসেজ পাঠায় যা ইঙ্গিত দেয় যে মডেলটি প্রতিক্রিয়া তৈরি করা শেষ করেছে।
পাইথন
async for response in session.receive():
if response.server_content.generation_complete is True:
# The generation is complete
জাভাস্ক্রিপ্ট
const turns = await handleTurn();
for (const turn of turns) {
if (turn.serverContent && turn.serverContent.generationComplete) {
// The generation is complete
}
}
এরপর কি
সম্পূর্ণ সক্ষমতা নির্দেশিকা, টুল ব্যবহার পৃষ্ঠা বা লাইভ API কুকবুকে লাইভ API-এর সাথে কাজ করার আরও উপায়গুলি অন্বেষণ করুন৷